iv3jdv/fleet-control-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

Fix: MQTT connection

Browse Source
This commit is contained in:
Roby
2026-04-26 14:32:07 +02:00
parent 509d673489
commit 75150f36b1
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app.py
+6 -1
View File
@@ -381,8 +381,13 @@ mqtt_backend.username_pw_set(config['mqtt']['user'], config['mqtt']['password'])
mqtt_backend.on_connect = on_connect mqtt_backend.on_connect = on_connect
mqtt_backend.on_disconnect = on_disconnect mqtt_backend.on_disconnect = on_disconnect
mqtt_backend.on_message = on_message mqtt_backend.on_message = on_message
mqtt_backend.connect(config['mqtt']['broker'], config['mqtt']['port']) 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() 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('/') @app.route('/')
def index(): return render_template('index.html') def index(): return render_template('index.html')