caspia.toolbox.integrations.influxdb package

Submodules

caspia.toolbox.integrations.influxdb.cli module

caspia.toolbox.integrations.influxdb.influxdb module

class caspia.toolbox.integrations.influxdb.influxdb.InfluxDBConnector(consumer_conn: caspia.meadow.client.connection.consumer.ConsumerConnection, url: str, interval=5.0, db_name='notification')

Bases: object

Listens for all meadow notification and stores them to InfluxDB.

Initialize new InfluxDBConnector. :param consumer_conn: Prepared meadow consumer connection to use for event listening. :param url: Url of the influxdb server. :param interval: Minimum interval for writing notifications to influxdb.

async start()

Module contents