Python MQTT 连接到 Azure Iot Hub

Question

我想使用 Python MQTT 连接到 Azure Iot Hub。

Iot Hub 需要用户名和 SAS token 。这是我的代码:

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    client.subscribe("$SYS/#")

def on_message(client, userdata, msg):
    print(msg.topic+" "+str(msg.payload))

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message

client.username_pw_set("myHub.azure-devices.net/device1", "mySASToken")

client.connect("myHub.azure-devices.net", 1883, 60)

client.loop_forever()

但是运行一段时间后，抛出这个异常:

TimeoutError: [WinError 10060] 连接尝试失败，因为连接方在一段时间后没有正确响应，或者由于连接的主机未能响应而建立的连接失败

有人知道为什么我无法连接到物联网中心吗？

Answer 1

现在有一个官方的 Python SDK 可将设备连接到 Azure IoT 中心: https://github.com/Azure/azure-iot-sdks/tree/master/python/device

This sample演示如何使用 MQTT 协议(protocol)进行连接。

基本上，它的工作原理如下:

1. 创 build 备客户端并指定协议(protocol)为 MQTT
2. 设置收到消息时调用的回调
3. 使用 send_event_async 将消息发送到您的 Azure IoT 中心实例。

from iothub_client import *

def send_confirmation_callback(message, result, userContext):
    print "Confirmation[%d] received for message with result = %s" % (userContext, result)

def receive_message_callback(message, counter):
    buffer = message.get_bytearray()
    size = len(buffer)
    print "Received Message"
    print "    Data: <<<%s>>> & Size=%d" % (buffer[:size], size)
    return IoTHubMessageDispositionResult.ACCEPTED

iotHubClient = IoTHubClient(connectionString, IoTHubTransportProvider.MQTT)
iotHubClient.set_message_callback(receive_message_callback, 0)
iotHubClient.send_event_async(message, send_confirmation_callback, 0)