29 lines
952 B
Python
29 lines
952 B
Python
from influxdb_client import InfluxDBClient, Point, WritePrecision
|
|
from datetime import datetime
|
|
|
|
class DataBaseInflux:
|
|
def __init__(self, url: str, token: str, org: str, bucket: str):
|
|
self.url = url
|
|
self.token = token
|
|
self.org = org
|
|
self.bucket = bucket
|
|
self.client = InfluxDBClient(url=self.url, token=self.token, org=self.org)
|
|
self.write_api = self.client.write_api()
|
|
|
|
def store_data(self, device_name: str, data: dict):
|
|
measurement = device_name # Fest auf "messungen" gesetzt
|
|
|
|
point = Point(measurement)
|
|
|
|
# Alle Key/Value-Paare als Fields speichern
|
|
for key, value in data.items():
|
|
point = point.field(key, value)
|
|
|
|
# Zeitstempel automatisch auf jetzt setzen
|
|
point = point.time(datetime.utcnow(), WritePrecision.NS)
|
|
|
|
# Punkt in InfluxDB schreiben
|
|
self.write_api.write(bucket=self.bucket, org=self.org, record=point)
|
|
|
|
|