如何用Python读取Azure IoT Hub设备消息？连接断开错误求助

ConnectionDroppedError: Unexpected disconnection 是设备与Azure IoT Hub的连接意外中断引发的错误，以下是针对性的排查和修复方案：

1. 确认连接字符串正确性 #

你的代码中connection_string = "="是无效配置，必须替换为Azure门户中获取的设备专属连接字符串，格式应为：

HostName={你的IoT Hub名称}.azure-devices.net;DeviceId={设备ID};SharedAccessKey={设备密钥}

连接字符串错误会直接导致设备无法建立有效连接，触发断开异常。

2. 添加异常捕获与自动重连逻辑 #

原代码未处理连接中断的异常，后台线程报错后无法自行恢复。需要在代码中捕获传输层异常，并实现重连逻辑：

修改后的完整代码：

import time
from azure.iot.device import IoTHubDeviceClient
from azure.iot.device.common.transport_exceptions import ConnectionDroppedError, TransportError

RECEIVED_MESSAGES = 0

# 替换为你的设备连接字符串
connection_string = "HostName=xxx.azure-devices.net;DeviceId=xxx;SharedAccessKey=xxx"

def message_handler(message):
    global RECEIVED_MESSAGES
    RECEIVED_MESSAGES += 1
    print("")
    print("Message received:")

    # 打印系统属性和自定义属性
    for property in vars(message).items():
        print("    {}".format(property))

    print("Total calls received: {}".format(RECEIVED_MESSAGES))

def create_client():
    # 创建客户端实例并绑定消息处理器
    client = IoTHubDeviceClient.create_from_connection_string(connection_string)
    client.on_message_received = message_handler
    return client

def main():
    print("Starting the Python IoT Hub C2D Messaging device sample...")
    client = create_client()

    print("Waiting for C2D messages, press Ctrl-C to exit")
    while True:
        try:
            # 确保客户端处于连接状态
            if not client.connected:
                client.connect()
            time.sleep(10)
        except KeyboardInterrupt:
            print("IoT Hub C2D Messaging device sample stopped")
            break
        except (ConnectionDroppedError, TransportError) as e:
            print(f"Connection dropped, reconnecting: {str(e)}")
            client.shutdown()
            client = create_client()
        except Exception as e:
            print(f"Unexpected error: {str(e)}")
            time.sleep(5)
    finally:
        print("Shutting down IoT Hub Client")
        client.shutdown()

if __name__ == '__main__':
    main()

3. 排查网络与防火墙限制 #

• 确保设备能访问Azure IoT Hub的公共端点，测试端口连通性：

  telnet {你的IoT Hub名称}.azure-devices.net 8883
  

  （MQTT协议默认用8883端口，HTTPS用443端口）
• 检查设备所在网络的防火墙、代理是否允许出站连接到上述端口。

4. 检查IoT Hub与设备状态 #

• 登录Azure门户，确认IoT Hub运行正常，未达到连接数、消息数等配额限制；
• 检查目标设备是否处于启用状态，没有被禁用或删除。

内容的提问来源于stack exchange，提问作者Juan Felipe Urrego Bran