我使用了来自https://docs.microsoft.com/de-de/azure/iot-hub/quickstart-send-telemetry-python的python示例将遥测数据发送到IoTHub。现在,我尝试通过一个自定义端点和一个路由,只将来自设备“testdevice”的消息转发到blob存储中。使用查询字符串“true”,来自所有设备的所有消息都被推送到存储器。但是,我没有让查询只选择来自deviceId“test device”的消息。我在文档中搜索,但没有找到任何有用的示例。。。在
有人能帮我查一下吗?至少,对IoHub内部的传入消息进行采样,以了解IoHub消息的结构(就像在StreamAnalytics“示例数据”中所做的那样)。在
您可以尝试在路由查询中使用
$connectionDeviceId = "{your device id}"
。connectionDeviceId
由IoT集线器标记在服务绑定消息上。我认为这比沉默的建议更简单。消息系统属性以“$”符号作为前缀。有关消息路由here的更多查询语言。有一篇关于消息路由here的非常好的博文。
例如,您可以在添加到消息中的任何属性或消息体中的任何字段上路由(如果它是UTF-8编码的JSON)。不确定默认情况下是否可以在deviceId上路由,但可以将属性
"testmessage": true
添加到消息中,然后有一个与之匹配的路由规则:"testmessage" = true
相关问题 更多 >
编程相关推荐