Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import paho.mqtt.client as mqtt
- import time
- # MQTT-Broker-Details
- broker_ip = "IP_DES_MQTT_BROKERS"
- broker_port = 1883 # oder 8883 für SSL
- # Verbindungsfunktion
- def on_connect(client, userdata, flags, rc):
- print(f"Verbunden mit dem Broker (Code {rc})")
- # Client erstellen und konfigurieren
- client = mqtt.Client("PCA3220_Client")
- client.on_connect = on_connect
- # Verbindungsaufbau
- client.connect(broker_ip, broker_port, 60)
- client.loop_start()
- # Beispieldaten senden
- while True:
- payload = "Beispieldaten" # Hier können die gewünschten Daten generiert werden
- client.publish("sensors/data", payload)
- print(f"Daten gesendet: {payload}")
- time.sleep(5) # Daten alle 5 Sekunden senden
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement