使用MQTT无法从Azure IoT Hub接收设备消息的问题求助

你遇到的核心问题是Azure IoT Hub的设备到云消息与云到设备消息是完全独立的通道：

• 发布代码将消息发送到设备到云主题（devices/edgedevice1/messages/events/），这类消息是设备上报给IoT Hub的
• 订阅代码监听的是云到设备主题（devices/edgedevice2/messages/devicebound/#），这类消息只能由IoT Hub服务端（而非其他设备）下发给设备

IoT Hub不会自动将一个设备的上报消息转发到另一个设备的云到设备通道，因此edgedevice2收不到消息。

要实现设备间消息通信，需要通过服务端中转的方式，流程如下：

1. edgedevice1发送设备到云消息到IoT Hub
2. 服务端程序从IoT Hub接收该消息
3. 服务端程序调用IoT Hub API，将消息作为云到设备消息发送给edgedevice2
4. edgedevice2监听云到设备主题接收消息

步骤1：优化发布代码（添加目标设备标识） #

给上报消息添加目标设备属性，方便服务端识别转发对象，修改发布代码的publish行：

client.publish(
    "devices/" + device_id + "/messages/events/",
    '{"id":123, "target_device": "edgedevice2"}',
    qos=1,
    retain=True
)

步骤2：编写服务端转发程序 #

使用Azure IoT Hub SDK编写Python服务端，实现消息接收与转发：

from azure.iot.hub import IoTHubRegistryManager
from azure.iot.hub.models import CloudToDeviceMessage

# 替换为你的IoT Hub连接字符串（Azure门户IoT Hub共享访问策略中获取）
IOTHUB_CONNECTION_STRING = "HostName=PASSDEMO1.azure-devices.net;SharedAccessKeyName=iothubowner;SharedAccessKey=你的密钥"

def forward_device_message():
    # 初始化注册表管理器
    registry_manager = IoTHubRegistryManager(IOTHUB_CONNECTION_STRING)
    
    # 生产环境建议用Event Hub SDK持续监听IoT Hub内置端点，此处为简化演示
    # 模拟接收edgedevice1的上报消息
    message_payload = '{"id":123, "target_device": "edgedevice2"}'
    target_device = "edgedevice2"
    
    # 构造并发送云到设备消息
    cloud_msg = CloudToDeviceMessage(message=message_payload)
    registry_manager.send_c2d_message(target_device, cloud_msg)
    print(f"消息已转发到设备：{target_device}")

if __name__ == "__main__":
    forward_device_message()

步骤3：确认订阅代码有效性 #

你的订阅代码逻辑本身无问题，需额外检查：

• edgedevice2的SAS Token未过期且格式正确
• Azure门户中edgedevice2的设备状态为「已启用」

• 原发布代码的SAS Token中存在多余空格（azure- devices.net），请删除空格避免后续认证失败
• 生产环境需用Event Hub SDK替代模拟接收逻辑，实现对IoT Hub设备到云消息的持续监听
• 若需高效的设备间通信，可配置IoT Hub消息路由，将设备消息转发到服务总线队列后再由服务端处理

内容的提问来源于stack exchange，提问作者Niescte