【发布时间】：2018-06-27 18:06:28
【问题描述】：
如何使用 Python 在事件中心接收设备消息？我看到来自事件中心的摘要消息，但缺少详细的设备消息。
使用 Azure IOT 远程监控示例（https://github.com/Azure/azure-iot-remote-monitoring、https://www.azureiotsolutions.com/Accelerators）和 IOT Hub Explorer https://github.com/Azure/iothub-explorer 提供如下消息：
==== 来自：'chiller-01.0' at '2018-06-27T17:35:13.835Z' ==== { “温度”：74.8813305672404， “温度单位”：“F”， “湿度”：67.345695720448， “湿度单位”：“％”， “压力”：155.648674178239， “压力单位”：“psig” } ---- 应用程序属性 ---- { "iothub-message-schema": "chiller-sensors;v1", “iothub-creation-time-utc”：“2018-06-27T17:35:13.5066336Z”， "$$CreationTimeUtc": "2018-06-27T17:35:13+00:00", "$$MessageSchema": "chiller-sensors;v1", "$$ContentType": "JSON" }
为了在 python 中获取这些消息，我使用 azure-event-hubs-python 库和https://github.com/Azure/azure-event-hubs-python 的示例使用为操作中的 IOT 中心指定的事件中心连接字符串从事件中心读取 IOT 消息标签。用 Node JS 编写的 IOT Hub Explorer 使用 IOT Hub 连接字符串，但是使用 python 编写相应的代码失败并且 EventHubClient.from_connection_string 失败，因为 'EndPoint' 不在连接字符串中。将连接字符串中的“HostName”更改为“EndPoint”会导致 connection.pyx 出现错误：
文件“./src/connection.pyx”，第 20 行，在 uamqp.c_uamqp.create_connection 类型错误：预期字节，找到无类型
将协议 sb:// 预挂到端点抱怨未指定 EventHub：
ValueError：未指定 EventHub
添加 ;EntityPath= 会更进一步，但会因 CBS 令牌身份验证错误而失败：
azure.eventhub.EventHubError：接收失败：CBS 令牌身份验证失败。 状态码：401 说明：b'指定的 SAS 令牌具有无效签名。它与主键或辅助键都不匹配。'
使用 IOT 中心的事件中心连接字符串连接并接收消息可修复这些错误，但仅接收摘要数据而没有任何设备遥测，例如：
{
"count": 0,
"total": 0,
"minimum": 0,
"maximum": 0,
"average": 0,
"resourceId": "/SUBSCRIPTIONS/{SUBSCRIPTION}/RESOURCEGROUPS/{RESOURCEGROUP}/PROVIDERS/MICROSOFT.DEVICES/IOTHUBS/{IOTHUB}",
"time": "2018-06-27T16:59:00.0000000Z",
"metricName": "jobs.failed",
"timeGrain": "PT1M"
}
由于设备数据丢失，我不确定是否将正确的参数传递给 Python EventHubClient，或者客户端是否没有返回它们。一年前的此堆栈交换How can I receive from Azure IoT Hub messages sent by devices? 表明无法使用 Python 读取遥测数据，但由于 Python EventHub SDK 已经存在，我希望这已得到修复。
【问题讨论】：
标签： python azure azure-iot-hub azure-eventhub azure-iot-sdk