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)