安装:pip install paho-mqtt 或 pip3 install paho-mqttimport paho.mqtt.client as mqtt# The callback for when the client receives a CONNACK response from the server.def on_connect(client, userdata, rc): print("Connected with result code "+str(rc)) # Subscribing in on_connect() 便宜美国vps means that if we lose the connection and # reconnect then subscriptions will be renewed. client.subscribe("$SYS/#")# The callback for when a PUBLISH message is received from the server.def on_message(client, userdata, msg): print(msg.topic+" "+str(msg.payload))client = mqtt.Client()client.on_connect = on_connectclient.on_message = on_messageclient.connect("iot.eclipse.org", 1883, 60)# Blocking call that processes network traffic, dispatches callbacks and# handles reconnecting.# Other loop*() functions are available that give a threaded interface and a# manual interface.client.loop_forever()待续... 34585199