Main.py

from dotenv import load_dotenv
import os

from mqtt_influx_backend.MQTTClientHandler import MQTTClientHandler
from mqtt_influx_backend.InfluxDBWriter import InfluxDBWriter

load_dotenv()

def main():
    influx_writer = InfluxDBWriter(
    url=os.getenv("INFLUXDB_URL"),
    token=os.getenv("INFLUXDB_TOKEN"),
    org=os.getenv("INFLUXDB_ORG"),
    bucket=os.getenv("INFLUXDB_BUCKET")
    )

    mqtt_handler = MQTTClientHandler(
    broker_url=os.getenv("MQTT_BROKER_URL"),
    topic=os.getenv("MQTT_TOPIC"),
    influx_writer=influx_writer
    )

    mqtt_handler.start()

if __name__ == "__main__":
    main()