From cb8f288f393031a86718cc98a715703578a74816 Mon Sep 17 00:00:00 2001 From: Stefan Regnery Date: Tue, 19 Sep 2023 15:57:24 +0200 Subject: [PATCH] add logging for debugging --- run.py | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) diff --git a/run.py b/run.py index 9c43cce..d3ca5ac 100644 --- a/run.py +++ b/run.py @@ -1,4 +1,5 @@ import asyncio +import logging import os import toml import paho.mqtt.client as mqtt @@ -25,15 +26,20 @@ async def main(): mqtt_client = mqtt.Client() mqtt_client.username_pw_set(config["mqtt"]["username"], config["mqtt"]["password"]) - mqtt_client.connect(config["mqtt"]["broker"], config["mqtt"]["port"]) + try: + mqtt_client.connect(config["mqtt"]["broker"], config["mqtt"]["port"]) + except: + logging.error("Invalid credentials, check your configuration.") + exit(2) while True: item = await queue.get() + logging.debug(item) for i in item.data: return_code, _ = mqtt_client.publish(f"{config['mqtt']['topic']}/{item.name}/{i}", item.data[i]) - if return_code == 4: - print("Invalid credentials, check your configuration.") - exit(1) + if return_code != 0: + await queue.put(item) + mqtt_client.reconnect() if __name__ == '__main__':