algatux / influxdb-bundle
Bundle service integration of official influxdb/influxdb-php client
Installs: 322 553
Dependents: 0
Suggesters: 1
Security: 0
Stars: 23
Watchers: 2
Forks: 14
Open Issues: 4
Type:symfony-bundle
Requires
- php: ^7.2 || ^8.0
- influxdb/influxdb-php: ^1.2
- symfony/console: ^4.4 || ^5.4 || ^6.4
- symfony/framework-bundle: ^4.4 || ^5.4 || ^6.4
Requires (Dev)
- matthiasnoback/symfony-dependency-injection-test: ^4.1
- phpspec/prophecy: ^1.10
- symfony/form: ^4.4 || ^5.4 || ^6.4
Suggests
- symfony/form: Needed for form types usage
- symfony/proxy-manager-bridge: Needed to lazy-load connection services
This package is auto-updated.
Last update: 2024-12-21 11:22:54 UTC
README
Bundle service integration of official influxdb/influxdb-php client
Installation
First of all, you need to require this library through composer:
composer require algatux/influxdb-bundle
Then, enable the bundle on the AppKernel
class:
// app/AppKernel.php public function registerBundles() { $bundles = array( // ... new Algatux\InfluxDbBundle\AlgatuxInfluxDbBundle(), ); // ... return $bundles }
Configuration
Here is the configuration reference:
algatux_influx_db: # If not defined, the first connection will be taken. default_connection: ~ connections: # Prototype name: # Your InfluxDB host address host: ~ # Required # Your InfluxDB database name database: ~ # Required # Set it to true to activate the UDP connection udp: false # Set it to true to enable SSL over HTTP (required for Influx Cloud) ssl: false # Set it to true to activate the ssl verification ssl_verification: false udp_port: 4444 http_port: 8086 username: '' password: '' # Setup timeout or connection timeout (seconds) for your requests timeout: 0.0 connect_timeout: 0.0 # Set it to false to disable the event listener configuration listener_enabled: true # Simple override for the default event listener class (constructor args and methods must match) listener_class: Algatux\InfluxDbBundle\Events\Listeners\InfluxDbEventListener
If you have only one connection to configure, this can be simplified to this:
algatux_influx_db: # Your InfluxDB host address host: ~ # Required # Your InfluxDB database name database: ~ # Required # Set it to true to activate the UDP connection udp: false # Set it to true to enable SSL over HTTP (required for Influx Cloud) ssl: false # Set it to true to activate the ssl verification ssl_verification: false udp_port: 4444 http_port: 8086 username: '' password: '' # Setup timeout or connection timeout (seconds) for your requests timeout: 0.0 connect_timeout: 0.0 # Set it to false to disable the event listener configuration listener_enabled: true # Simple override for the default event listener class (constructor args and methods must match) listener_class: Algatux\InfluxDbBundle\Events\Listeners\InfluxDbEventListener
Services
You can directly access to the InfluxDB\Database
through UDP or HTTP with those services:
$httpDatabase = $this->get('algatux_influx_db.connection.http'); // Default HTTP connection $udpDatabase = $this->get('algatux_influx_db.connection.udp'); // Default UDP connection // Same as before. $httpDatabase = $this->get('algatux_influx_db.connection.default.http'); $udpDatabase = $this->get('algatux_influx_db.connection.default.udp');
You can also retrieve them thanks to the registry:
$database = $this->get('algatux_influx_db.connection_registry')->getDefaultHttpConnection(); $database = $this->get('algatux_influx_db.connection_registry')->getDefaultUdpConnection(); // Same as before. $database = $this->get('algatux_influx_db.connection_registry')->getHttpConnection('default'); $database = $this->get('algatux_influx_db.connection_registry')->getUdpConnection('default');
To manipulate the database, please read the official documentation for reading and writing.
Sending data to influx db through events
Assuming this collection to send:
$time = new \DateTime(); $points = [new Point( 'test_metric', // name of the measurement 0.64, // the measurement value ['host' => 'server01', 'region' => 'italy'], // optional tags ['cpucount' => rand(1,100), 'memory' => memory_get_usage(true)], // optional additional fields $time->getTimestamp() )];
Dispatch the event instance according to the chosen writing protocol:
// UDP $container ->get('event_dispatcher') ->dispatch(InfluxDbEvent::NAME, new UdpEvent($points, Database::PRECISION_SECONDS)); // HTTP $container ->get('event_dispatcher') ->dispatch(InfluxDbEvent::NAME, new HttpEvent($points, Database::PRECISION_SECONDS));
Or, if you prefer to defer the event:
// Deferred Events // Collect your measurements during the request and make only one write to influxdb. // Deferred events are catched and "stored". Than on the kernel.terminate event one write per // event type and precision will be fired. // UDP $container ->get('event_dispatcher') ->dispatch(InfluxDbEvent::NAME, new DeferredUdpEvent($points, Database::PRECISION_SECONDS)); // HTTP $container ->get('event_dispatcher') ->dispatch(InfluxDbEvent::NAME, new DeferredHttpEvent($points, Database::PRECISION_SECONDS));
If you want to write to another connection than the default, you must specify it:
// UDP $container ->get('event_dispatcher') ->dispatch(InfluxDbEvent::NAME, new UdpEvent($points, Database::PRECISION_SECONDS, 'other_connection')); // HTTP $container ->get('event_dispatcher') ->dispatch(InfluxDbEvent::NAME, new HttpEvent($points, Database::PRECISION_SECONDS, 'other_connection'));
Commands
Some commands are provided:
algatux:influx:database:create
: To create the database.algatux:influx:database:drop
: To drop the database.
To get more information, run:
./app/console help <command>
Form types
This bundle provides several pre-defined form types. They are useful but optional.
If you want to use them, you have to require the symfony/form
package.
Description of each of them is on the class doc block. Here is a short usage example:
$form ->add('measurement', MeasurementType::class, [ 'connection' => 'default' // Optional: The connection you want to use. ]) ->add('fields', FieldKeyType::class, [ 'measurement' => 'cpu', // The concerned measurement. 'multiple' => true, // Parent type is ChoiceType. You can use parent option like multiple. ]) ->add('tags', TagKeyType::class, [ 'measurement' => 'cpu', 'exclude_host' => false, // True by default. Excludes the 'host' choice value. 'multiple' => true, ]) ->add('tag_value', TagValueType::class, [ 'measurement' => 'disk', 'tag_key' => 'fstype', // The related tag key. ]) ;
Custom event listeners
In order to make it more flexible, you can override or even completely disable the default event listener and implement your own.
It is useful i.e. if you want to add additional logging or error handling around the actual database calls.
Contributing
Feel free to contribute by opening a pull request, if you find a bug or to suggest a new feature. If you like docker, this repository is provided with a dev environment with some scripts to prepare and use it. All you need is docker and docker-compose installed on your system.
make setup # will build the needed containers and setup the project
make start # will start the needed containers and put you inside the php-cli container
make test # will launch the test suite
Note: All these scripts are meant to be used outside the containers.