与Azure Iot Hub的Python MQTT连接

2019-10-02 05:55:48 阅读：305 来源： 互联网

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

Iot Hub需要用户名和SAS令牌.这是我的代码：

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]连接尝试失败,因为连接方在一段时间后没有正确响应,或者建立的连接失败,因为连接的主机无法响应

有人知道为什么我无法连接到Iot Hub吗？

解决方法:

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

This sample演示了如何使用MQTT协议进行连接.

基本上,这是它的工作原理：

>创建设备客户端并为协议指定MQTT
>设置收到消息时将调用的回调
>使用send_event_async将消息发送到Azure IoT Hub实例.

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)

标签：mqtt,python,azure,azure-iot-hub
来源： https://codeday.me/bug/20191002/1841414.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

与Azure Iot Hub的Python MQTT连接