Demo for Mbed Connect Cloud board and an MQTT Python Broker/Client
Fork of MQTT-Python-Demo by
broker/broker.py
- Committer:
- Jenny Plunkett
- Date:
- 2017-11-17
- Revision:
- 2:9265bf2d9c37
File content as of revision 2:9265bf2d9c37:
import paho.mqtt.client as paho import socket # https://os.mbed.com/teams/mqtt/wiki/Using-MQTT#python-client # MQTT broker hosted on local machine mqttc = paho.Client() # Settings for connection host = "IP_ADDRESS_HERE" topic= "Mbed/#" # Callbacks def on_connect(self, mosq, obj, rc): print("Connected rc: " + str(rc)) def on_message(mosq, obj, msg): print("[Received] Topic: " + msg.topic + ", Message: " + str(msg.payload) + "\n"); def on_subscribe(mosq, obj, mid, granted_qos): print("Subscribed OK") def on_unsubscribe(mosq, obj, mid, granted_qos): print("Unsubscribed OK") # Set callbacks mqttc.on_message = on_message mqttc.on_connect = on_connect mqttc.on_subscribe = on_subscribe mqttc.on_unsubscribe = on_unsubscribe # Connect and subscribe print "Your IP address is:", socket.gethostbyname(socket.gethostname()) print("Connecting to " + host + "/" + topic) mqttc.connect(host, port=1883, keepalive=60) mqttc.subscribe(topic, 0) # Loop forever, receiving messages mqttc.loop_forever() print("rc: " + str(rc))