Untitled

import paho.mqtt.client as mqtt

# Callback-Funktion, die aufgerufen wird, wenn der Client eine Verbindung herstellt
def on_connect(client, userdata, flags, rc):
    print("Verbunden mit dem MQTT Broker mit Statuscode " + str(rc))
    
    # Subscribe auf ein Thema
    client.subscribe("test/temperatur")

# Callback-Funktion, die aufgerufen wird, wenn eine Nachricht empfangen wird
def on_message(client, userdata, msg):
    print(f"Nachricht empfangen: Thema: {msg.topic}, Inhalt: {msg.payload.decode()}")

# MQTT-Client erstellen
client = mqtt.Client()

# Callback-Funktionen setzen
client.on_connect = on_connect
client.on_message = on_message

# Verbindung zu einem MQTT-Broker herstellen (z.B. localhost)
client.connect("mqtt.eclipseprojects.io", 1883, 60)

# Startet eine Endlosschleife, die auf Nachrichten wartet und die Callbacks aufruft
client.loop_start()

# Veröffentlichen einer Nachricht auf dem Thema "test/temperatur"
client.publish("test/temperatur", "22.5")

# Halte das Skript am Laufen, damit es Nachrichten empfangen kann
try:
    while True:
        pass
except KeyboardInterrupt:
    print("Programm beendet")

# Verbindung trennen
client.loop_stop()
client.disconnect()