Python paho-MQTT 与 Azure IoT-Hub 的连接

Question

我正在尝试使用 MQTT 连接 Azure IoT-Hub 并发送和接收消息。

我正在关注给定的官方文档 here

但它总是与结果代码断开连接：1，尽管它从未进入 on_connect 函数。但是如果我尝试在函数之外发布它（连接字符串后注释掉的行），它会进入 on_publish 方法。

我这里使用的设备是我在Azure IoT Suite中创建的模拟设备

这是我使用的代码

from paho.mqtt import client as mqtt


def on_connect(client, userdata, flags, rc):
    print "Connected with result code: %s" % rc
    client.subscribe("devices/MyTestDevice02/messages/devicebound/#")
    client.publish("devices/MyTestDevice02/messages/events", "Hello World!")


def on_disconnect(client, userdata, rc):
    print "Disconnected with result code: %s" % rc


def on_message(client, userdata, msg):
    print " - ".join((msg.topic, str(msg.payload)))
    client.publish("devices/MyTestDevice02/messages/events", "REPLY", qos=1)


def on_publish(client, userdata, mid):
    print "Sent message"


client = mqtt.Client("MyTestDevice02", mqtt.MQTTv311)
client.on_connect = on_connect
client.on_disconnect = on_disconnect
client.on_message = on_message
client.on_publish = on_publish
client.username_pw_set(username="USERNAME.azure-devices.net/MyTestDevice02",
                       password="SharedAccessSignature=SharedAccessSignature sr=USERNAME.azure-devices.net%2fdevices%2fMyTestDevice02&sig=xxxxxx5rRr7c%3d&se=1492318301")
client.tls_insecure_set(True) # You can also set the proper certificate using client.tls_set()
client.connect("USERNAME.azure-devices.net", port=8883)
#client.publish("devices/MyTestDevice02/messages/events", "Hello World!")
client.loop_forever()

感谢任何帮助。而且我不想使用 sdk，这就是我尝试直接发布它的原因。

Answer 1

您尚未启用 TLS - 您将需要使用 tls_set() 将 CA 证书传递给信任。单独使用 tls_insecure_set() 没有任何作用。

Answer 2

MS TechNet https://social.technet.microsoft.com/Forums/en-US/0c2cc683-c50f-428c-90ca-eeff132ba5e9/python-azure-iot-hub-mqtt-direct-with-basic-library?forum=windowsazuredevelopment 中有一个类似的帖子。

我建议您可以尝试使用其他支持Azure IoTHub的语言，例如Node.js或Java。

同时，您可以参考我的建议，通过使用其他支持语言扩展 Python，在 SO 线程 Python MQTT connection to Azure Iot Hub 中将 Azure IoTHub 与 Python 结合使用。

如有任何疑问，请随时告诉我。

Answer 3

问题终于解决了。这是设置 tls 的问题，出于某种原因我无法在 python 中做到这一点，所以我使用了 C#，

这是一个简单的版本。

client = new MqttClient("MyTestHub.azure-devices.net", 8883, true, MqttSslProtocols.TLSv1_0, null, null);
byte code = client.Connect("MyDevice1", "MyTestHub.azure-devices.net/MyDevice123","Use My SAS token");
ushort msgId = client.Publish("devices/MyDevice1/messages/events/", Encoding.UTF8.GetBytes("Test Message"), 1, false);

我为 MQTT 使用了 Nuget 库。

Python paho-MQTT 与 Azure IoT-Hub 的连接

Python paho-MQTT connection with azure IoT-Hub

python

azure

mqtt

mosquitto

azure-iot-hub