import time
|
import paho.mqtt.client as mqtt
|
|
def on_connect(client, userdata, flags, rc):
|
print("Connected with result code: " + str(rc))
|
|
def on_message(client, userdata, msg):
|
print(msg.topic + " " + str(msg.payload))
|
|
def publish_data(jsondata):
|
print("publish data sucess>>>>>>>>>>>>>>>>>>>>>")
|
|
def on_disconnect(client, userdata, rc):
|
print("-- Disconnection returned result:" + str(rc))
|
|
def on_subscribe(client, userdata, mid, granted_qos):
|
print("-- on_subscribe returned mid:" + str(mid))
|
|
# 连接服务器的参数
|
def publish_para():
|
client = mqtt.Client(client_id="your_id0", clean_session=False)
|
client.on_connect = on_connect
|
client.on_message = on_message
|
client.on_disconnect = on_disconnect
|
client.connect("222.71.114.83", 7038)
|
client.loop_start()
|
return client
|
|
def mqtt_on_publish_to_cloud(topic, message_dict):
|
# 判断指令是否发送成功
|
client = publish_para()
|
while True:
|
payload = str(message_dict)
|
client.publish(topic, payload)
|
print(payload)
|
print("mqtt向云端发送指令成功")
|
time.sleep(2)
|
|
if __name__ == '__main__':
|
topic = "mqtt向云端发送指令"
|
message_dict = {"发送指令" :"成功"}
|
|
# mqtt向云端发送指令成功函数
|
mqtt_on_publish_to_cloud(topic, message_dict)
|
