A simple python interface for InfluxDB2.0
Project description
SFLUX
Simple Influx DB wrapper for python. Builds on top of influxdb-client to make the use of Influxdb as simple as possible
Basic Usage
1. Querying data
Sflux transforms the FluxQL syntaxis into intuitive python commands that try to follow FluxQL as close as possible. A simple query looks like this:
import sflux
with sflux.Client(url='your_host', token='your_token', org='your_org') as client:
result = client.query(bucket='your_bucket')\
.range(start='-1d')\
.filter(sflux.ROW('measurement') == 'your_measurement')\
.pivot()\
.filter(sflux.ROW('your_column') != 'something')\
.to_dict()
2. Writing data
The writing of time series into the database is acheived by building measurement objects for each measurement to be inserted:
import time
import sflux
measurements = [
sflux.Measurement('measurement_name', field1='value1', field2='value2')
.tags(tag1='tag1', tag2='tag2')
.time(time.time())
]
with sflux.Client(url='your_host', token='your_token', org='your_org') as client:
client.write('your_bucket', measurements)
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
sflux-0.0.22.tar.gz
(7.6 kB
view hashes)
Built Distribution
sflux-0.0.22-py3-none-any.whl
(7.8 kB
view hashes)