snsary.contrib.influxdb

Sends batches of Readings as “points” to a specified InfluxDB bucket at a specified endpoint e.g. InfluxDB Cloud. Each point is named after the Reading and tagged by sensor and host.

Create an instance with .from_env(), which expects:

  • INFLUXDB_URL

  • INFLUXDB_TOKEN

  • INFLUXDB_ORG

  • INFLUXDB_BUCKET

Module Contents

class snsary.contrib.influxdb.InfluxDBOutput(*, url, token, org, bucket)

Bases: snsary.outputs.BatchOutput

classmethod from_env()
publish_batch(readings)