34 lines
1.1 KiB
Python
34 lines
1.1 KiB
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, data: dict):
|
|
measurement = "messungen" # 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)
|
|
|
|
db = DataBaseInflux(
|
|
url="http://localhost:8086",
|
|
token="Cw_naEZyvJ3isiAh1P4Eq3TsjcHmzzDFS7SlbKDsS6ZWL04fMEYixWqtNxGThDdG27S9aW5g7FP9eiq5z1rsGA==",
|
|
org="allmende",
|
|
bucket="allmende_db"
|
|
)
|