From 45dd394b6024eea63f9086289f25b4173cb3e978 Mon Sep 17 00:00:00 2001 From: derlole <122916573+derlole@users.noreply.github.com> Date: Wed, 16 Apr 2025 16:13:10 +0000 Subject: [PATCH] joa --- server.py | 11 +++-------- 1 file changed, 3 insertions(+), 8 deletions(-) diff --git a/server.py b/server.py index 64b65ec..ff57f53 100644 --- a/server.py +++ b/server.py @@ -46,7 +46,6 @@ socketio = SocketIO(app, cors_allowed_origins="*") # MQTT Setup mqtt_client = mqtt.Client(protocol=mqtt.MQTTv5) -# Funktion für den Empfang von MQTT-Nachrichten def on_mqtt_message(client, userdata, msg): payload = msg.payload.decode() print(f"[MQTT] {msg.topic}: {payload}") @@ -55,18 +54,14 @@ def on_mqtt_message(client, userdata, msg): mqtt_client.on_message = on_mqtt_message mqtt_client.connect("localhost", 1883) # MQTT-Broker-Adresse -mqtt_client.subscribe("lires/esp1/status") # MQTT-Topic, das abonniert werden soll -mqtt_client.loop_start() # Starten des MQTT-Client-Loops in einem separaten Thread +mqtt_client.subscribe("lires/esp1/status") +mqtt_client.loop_start() -# Socket.IO → MQTT: Empfangene Daten von Socket.IO an MQTT senden @socketio.on("send_to_esp") def handle_send(data): - mqtt_client.publish("lires/esp1/control", data) # MQTT-Message senden + mqtt_client.publish("lires/esp1/control", data) -# Blueprint registrieren app.register_blueprint(unsecure) -# Starten der Flask-SocketIO-Anwendung if __name__ == '__main__': - # Verwende socketio.run() statt app.run() für asynchrone WebSocket-Kommunikation socketio.run(app, host="0.0.0.0", port=3060)