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)