以下是一个简单的 Python 示例代码，用于通过 MQTT 协议向指定主机 (`sh-3-mqtt.iot-api.com`) 上报温度数据。我们将使用 `paho-mqtt` 库作为客户端实现。 ### 实现步骤 #### 1. 安装依赖库 首先，确保已经安装了 `paho-mqtt` 模块： ```bash pip install paho-mqtt ``` #### 2. 编写代码 以下是完整的示例代码： ```python import paho.mqtt.client as mqtt import time import random # MQTT 参数配置 MQTT_HOST = "sh-3-mqtt.iot-api.com" MQTT_PORT = 1883 USERNAME = "<你的用户名>" # 替换为实际的 Username PASSWORD = "<你的密码>" # 替换为实际的 Password TOPIC = "temperature/data" # 自定义主题名称 # 创建 MQTT 客户端实例 client_id = f"TemperatureSensor_{random.randint(1000,9999)}" client = mqtt.Client(client_id) # 设置登录认证信息 client.username_pw_set(USERNAME, PASSWORD) # 连接回调函数 def on_connect(client, userdata, flags, rc): if rc == 0: print("成功连接到 MQTT Broker") else: print(f"连接失败，返回码: {rc}") # 发布消息回调函数 def on_publish(client, userdata, mid): print(f"消息发布成功，ID={mid}") # 绑定回调函数 client.on_connect = on_connect client.on_publish = on_publish try: # 连接到 broker client.connect(MQTT_HOST, MQTT_PORT) # 启动网络循环 (异步处理) client.loop_start() while True: # 随机生成温度值 temperature = round(random.uniform(20.0, 35.0), 2) # 温度范围：20°C ~ 35°C # 构造 JSON 格式的 payload 数据 payload = { "device": "sensor_001", "temperature": temperature, "unit": "°C" } # 将字典转换为字符串形式发送 import json message = json.dumps(payload) # 发送消息至指定 topic result = client.publish(TOPIC, message, qos=1) if result[0] == 0: print(f"已发送消息: {message}") else: print("消息发送失败!") # 每隔 5 秒发送一次数据 time.sleep(5) except KeyboardInterrupt: print("\n程序中断") finally: # 断开连接并停止循环 client.disconnect() client.loop_stop() print("断开了与 MQTT Broker 的连接") ``` --- ### 关键说明 1. **替换占位符** - `<你的用户名>` 和 `<你的密码>` 必须替换为您从平台获取的实际凭据。 2. **Topic 名称** - 可自定义 Topic（如 `"temperature/data"`），也可以根据业务需求调整。 3. **随机数种子** - 使用 `random.randint()` 来模拟设备编号或动态生成唯一 ID；同时用 `random.uniform()` 提供虚假温度数据。 4. **异常捕获** - 添加 `KeyboardInterrupt` 异常捕获以便用户能安全退出脚本运行，并清理资源。 --- ###