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()