Skip to content
Asynchronous Python client for InfluxDB
Branch: master
Clone or download
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
.circleci Update CircelCI config Mar 9, 2019
aioinflux Update CHANGELOG and bump version May 10, 2019
docs Update docs to reflect dataframe support for chunked queries May 9, 2019
notebooks
tests Flake8 May 9, 2019
.gitignore Update Makefile Jul 23, 2018
.readthedocs.yml Debug RTD settings Jul 23, 2018
CHANGELOG.md Update CHANGELOG and bump version May 10, 2019
LICENSE Create LICENSE Jun 16, 2017
Makefile Fix coverage issue Apr 11, 2019
README.rst Show master CircleCI badge Mar 8, 2019
pytest.ini Move pytest config out of setup.cfg (pytest-dev/pytest#3062) Mar 9, 2019
setup.cfg Change flake8 config Apr 11, 2019
setup.py Fix flake8-rst-docstrings dependency issue Mar 9, 2019
tox.ini Add dataframe support for chunked queries May 9, 2019

README.rst

aioinflux

CI status Coverage PyPI package Supported Python versions Documentation status

Asynchronous Python client for InfluxDB. Built on top of aiohttp and asyncio. Aioinflux is an alternative to the official InfluxDB Python client.

Aioinflux supports interacting with InfluxDB in a non-blocking way by using aiohttp. It also supports writing and querying of Pandas dataframes, among other handy functionality.

Please refer to the documentation for more details.

Installation

Python 3.6+ is required. You also need to have access to a running instance of InfluxDB.

pip install aioinflux

Quick start

This sums most of what you can do with aioinflux:

import asyncio
from aioinflux import InfluxDBClient

point = {
    'time': '2009-11-10T23:00:00Z',
    'measurement': 'cpu_load_short',
    'tags': {'host': 'server01',
             'region': 'us-west'},
    'fields': {'value': 0.64}
}

async def main():
    async with InfluxDBClient(db='testdb') as client:
       await client.create_database(db='testdb')
       await client.write(point)
       resp = await client.query('SELECT value FROM cpu_load_short')
       print(resp)


asyncio.get_event_loop().run_until_complete(main())

See the documentation for more detailed usage.

You can’t perform that action at this time.