paho_mqtt_broker_subscribe_and_print_messages.py

1import paho.mqtt.client as mqtt
2
3# The callback for when the client receives a CONNACK response from the server.
4def on_connect(client, userdata, flags, rc):
5    print("Connected with result code "+str(rc))
6
7    # Subscribing in on_connect() means that if we lose the connection and
8    # reconnect then subscriptions will be renewed.
9    client.subscribe("$SYS/#")
10
11# The callback for when a PUBLISH message is received from the server.
12def on_message(client, userdata, msg):
13    print(msg.topic+" "+str(msg.payload))
14
15client = mqtt.Client()
16client.on_connect = on_connect
17client.on_message = on_message
18
19client.connect("mqtt.eclipseprojects.io", 1883, 60)
20
21# Blocking call that processes network traffic, dispatches callbacks and
22# handles reconnecting.
23# Other loop*() functions are available that give a threaded interface and a
24# manual interface.
25client.loop_forever()