按消息类型将事件中心消息路由到 Azure 函数
Routing Event Hub messages to Azure funtion by message type
我创建了一个 Azure 函数来侦听 Azure IoT 中心实例。当我向 IoT 中心发送 post 消息时,我设置了一个 属性,如下所示:
Message iotMessage = new Message([myMessage]);
iotMessage.Properties.Add("Type", [MessageType]);
在 Azure 函数端,我希望 Azure 函数仅发送 receive/process 类型为 属性 且类型 属性 等于 "MessageType1" 的消息。
我看不到在 Azure 函数中执行此操作的方法。有人可以建议这是否可行吗?
编辑:这似乎是您要查找的内容:
您的条件将是 Type=MessageType1,并且您将触发输出队列中的函数。
您的 Azure 函数使用什么类型的输入绑定?
据我所知,这目前无法一步完成。但是,您有几个选择:
- 将 IoT 中心连接到 ServiceBus Topic/Subscription,这允许您根据属性进行一些过滤。触发按 MessageType1
筛选的订阅
- 具有专门用于过滤 IoT 中心消息的功能。当它匹配 MessageType1 消息时,将该消息放入队列中。此队列触发另一个仅处理匹配消息的函数
我创建了一个 Azure 函数来侦听 Azure IoT 中心实例。当我向 IoT 中心发送 post 消息时,我设置了一个 属性,如下所示:
Message iotMessage = new Message([myMessage]);
iotMessage.Properties.Add("Type", [MessageType]);
在 Azure 函数端,我希望 Azure 函数仅发送 receive/process 类型为 属性 且类型 属性 等于 "MessageType1" 的消息。
我看不到在 Azure 函数中执行此操作的方法。有人可以建议这是否可行吗?
编辑:这似乎是您要查找的内容:
您的条件将是 Type=MessageType1,并且您将触发输出队列中的函数。
您的 Azure 函数使用什么类型的输入绑定?
据我所知,这目前无法一步完成。但是,您有几个选择:
- 将 IoT 中心连接到 ServiceBus Topic/Subscription,这允许您根据属性进行一些过滤。触发按 MessageType1 筛选的订阅
- 具有专门用于过滤 IoT 中心消息的功能。当它匹配 MessageType1 消息时,将该消息放入队列中。此队列触发另一个仅处理匹配消息的函数