InfluxDB

dtbox.influxdb.InfluxDB

Tato třída poskytuje zjednodušenné rozhraní pro zápis do databáze InfluxDB. Rozhraní je kompatibilní s InfluxDB v1.8 a v2.*, přičemž využívá api v2 (více infromací zde).

Konstruktor

InfluxDB( host, auth, bucket, measurement, organisation=None, **tags)

Parametr	v1.8	v2.*
host	URL InfluxDB serveru
auth	jmeno:heslo1	API klíč
bucket	Název databáze2	Název bucketu
measurement	Název měření
organisation	-	Název organizace
**tags	Tagy pro měření např. place='Praha'

¹ Přihlašovací údaje uživatele InfluxDB ve tvaru jmeno:heslo (např. pepa:1234)

² Název databáze a retention policy ve tvaru databaze:retention-policy

Ukázka

from dtbox.influxdb import InfluxDB

influxdb = InfluxDB(host='influxdb.example.xyz', auth='api_adsfydfgx5g4==', bucker='some_bucket', measurement='weather', organistaion='exampleorg')

Metody

from_config

def from_config()

Vytvoří instanci s hodnotami z konfigurace

Ukázka

influxdb = InfluxDB.from_config()

set_measurement

def set_measurement(measurement)

Nastaví název měření

• measurement - název měření

Ukázka

influxdb.set_measurement('weather')

set_tag

def set_tag(name, value)

Nastaví další tag

• **kwargs - tagy

Ukázka

influxdb.set_tag('id', '1')

set_tags

def set_tags(**kwargs)

Nastaví všechny tagy

• **kwargs - tagy

Ukázka

influxdb.set_tags({'id': '1'})

write

def write(**fields)

Zapíše do databáze

• **fields - data k zapsání do databáze

Ukázka

influxdb.write(temperature=25.2, humidity=45)