Skip to main content

Minimal and smart pusher of samples to InfluxDB for asyncio programs

Project description

Latest PyPI version

Minimal and smart pusher of samples to InfluxDB for asyncio programs


  1. Create a InfluxDbPusher object
  2. Call it to push samples
  3. InfluxDbPusher will try to do intelligent aggregation of samples in the background to minimise the number of HTTP request to the InfluxDb server.


import asyncio
import logging
from influxdbpusher import InfluxDbPusher

async def test():
    influx = InfluxDbPusher("http://influxdb:8086", "playground")
    while True:
        for dummy in range(10):
            await asyncio.sleep(0.02)
            influx("test", dummy, {"foo": "bar"})
                   {"fieldname1": 'hello "world"', "value": 2.0},
                   {"foo": "bar"})
        await asyncio.sleep(5)
    await influx.close()

if __name__ == '__main__':


pip install influxdbpusher


  • Python >= 3.5
  • aiohttp



MIT License

Copyright (c) 2017, Gambit Research


influxdbpusher was written by Gustavo Carneiro.

Project details

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Files for influxdbpusher, version 0.1.3
Filename, size File type Python version Upload date Hashes
Filename, size influxdbpusher-0.1.3-py3-none-any.whl (6.1 kB) File type Wheel Python version 3.6 Upload date Hashes View
Filename, size influxdbpusher-0.1.3.tar.gz (3.8 kB) File type Source Python version None Upload date Hashes View

Supported by

Pingdom Pingdom Monitoring Google Google Object Storage and Download Analytics Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page