下面是一个简单的Python示例程序，展示如何通过MQTT协议将数据发送到云平台： ```python import paho.mqtt.client as mqtt # 定义回调函数 - 连接到服务器后触发 def on_connect(client, userdata, flags, rc): if rc == 0: print("Connected successfully") else: print(f"Bad connection Returned code={rc}") # 创建 MQTT 客户端实例 client = mqtt.Client() # 绑定回调函数 client.on_connect = on_connect # 替换为您实际使用的用户名、密码和Broker地址 broker_address = "your.broker.address" username = 'your_username' password = 'your_password' # 设置登录凭证（如果有） if username and password: client.username_pw_set(username=username, password=password) try: # 尝试连接至 Broker client.connect(broker_address) except Exception as e: print(f"Could not connect to broker {e}") else: # 开始循环处理网络事件 (保持连接状态) client.loop_start() topic = "/test/topic" # 发布的主题名称 payload = "{ \"data\": 123 }" # 要发布的消息内容 for _ in range(5): # 示例连续发布五次消息 result = client.publish(topic=topic,payload=payload,qos=1,retain=False) status = result[0] if status != 0: print(f"Failed to send message to topic {topic}") time.sleep(1) # 等待一秒再继续下一次发布 finally: # 停止客户端并断开连接 client.disconnect() client.loop_stop() ``` 此脚本首先导入必要的库`paho-mqtt`,然后定义了一个当成功建立与代理之间的TCP/IP会话时调用的 `on_connect()` 回调函数 。之后创建一个 MQTT Client 对象并且指定上述回调作为它的属性值。接着配置好所有需要的身份认证信息以后尝试发起连接请求。一旦连上就启动后台线程支持异步 IO 操作以便于维持长期存活的状态同时可以正常收发各类通知等等；最后演示了在一个固定的时间间隔内不断往某个 Topic 下推送 JSON 格式的 Payload 数据直到完成既定次数为止。 注意在运行之前请修改对应的变量如 Broker 的 IP 地址或者是 Port 号码还有账户凭据等相关字段使之适应自身环境需求！