From 75150f36b1e5363daec3d459916d2bb797008263 Mon Sep 17 00:00:00 2001 From: Roby Date: Sun, 26 Apr 2026 14:32:07 +0200 Subject: [PATCH] Fix: MQTT connection --- app.py | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/app.py b/app.py index 2d0443e..2cf8c22 100644 --- a/app.py +++ b/app.py @@ -381,8 +381,13 @@ mqtt_backend.username_pw_set(config['mqtt']['user'], config['mqtt']['password']) mqtt_backend.on_connect = on_connect mqtt_backend.on_disconnect = on_disconnect mqtt_backend.on_message = on_message -mqtt_backend.connect(config['mqtt']['broker'], config['mqtt']['port']) -mqtt_backend.loop_start() +try: + # Usiamo connect_async! Non blocca il server se l'IP รจ irraggiungibile + mqtt_backend.connect_async(config['mqtt']['broker'], config['mqtt']['port']) + mqtt_backend.loop_start() + logger.info(f"Avvio connessione MQTT asincrona verso {config['mqtt']['broker']}...") +except Exception as e: + logger.error(f"Errore critico nell'inizializzazione MQTT: {e}") @app.route('/') def index(): return render_template('index.html')