使用 Python 发布到 Azure IoT 中心 - 使用 C# 订阅不起作用

Question

我在设备上使用 M2MQTT Paho Python 库发布如下：

    msg = "POS {} {} {} {} {} {} {}"

    msgtosend=msg.format(tagNum, tagID, x_pos, y_pos, z_pos, qos, unk)
    print(msgtosend)
    # qos=1 - (must be when clean_session is False) 
    mqttinfo=rpiclient.publish("dwm/position", msgtosend, 1) 
    if mqttinfo.rc != 0:
        print("Publishing message with ID {) failed. Error Code={}".format(mqttinfo.mid, mqttinfo.rc))

然后，我尝试使用 M2MQTT C# 库（成功连接到 Azure IoT Hub 后）再次读取 C# 应用程序中的数据，如下所示：

    tpc[0] = "devices/MasterTag/messages/devicebound/#";
    tpc[1] = "$iothub/twin/PATCH/properties/desired/#";
    tpc[2] = "$iothub/methods/POST/#";
    tpc[3] = "$iothub/twin/res/#";

    mqttClient.Subscribe(tpc, qosArray);

其中 qosArray 只有一项，它是 0 或 1。 ...然而，我没有收到任何消息。事实上，我的回调 MqttClient_MqttMsgSubscribed 也没有被调用，这意味着订阅不成功，但我没有收到错误消息或异常......

Answer 1

尝试以下修复：

tpc = new string[] { 
    "devices/MasterTag/messages/devicebound/#",
    "$iothub/twin/PATCH/properties/desired/#",
    "$iothub/methods/POST/#", 
    "$iothub/twin/res/#"
    };

qosArray = new byte[] { 
    MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE, 
    MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE, 
    MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE,
    MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE
   };

var subCode = mqttClient.Subscribe(tpc, qosArray);