从Azure IoT中心发送的事件中的会话行为

问题描述

我们正在基于Azures Edge运行时开发应用程序。我们的应用程序将消息上游发送到云,再发送到IoT中心,后者又定义了发送到不同服务总线队列的路由。这是一个简单的图像:

enter image description here

在这些队列中的一个上,我们关心 sessions ,这意味着我们需要批量接收每个事件并对其进行处理以按功能执行。我们注意到的问题是,当我们的应用程序快速连续产生事件时,会发生这种情况:

  1. 一个事件到来
  2. 数据库获取的与事件数据相对应的模型
  3. 模型已更新
  4. 将模型放置在传出的Cosmos绑定上
  5. 在触发宇宙输出绑定之前,下一个事件到来,使功能保持打开状态
  6. 从db中获取的与事件数据之前相对应的模型,先前的事件数据已被持久保存,这意味着我们将对已经过时的数据进行处理

我研究了服务总线队列会话,这似乎可以解决此问题,但是会话与IoT中心不兼容。我们也没有创建放置在队列中的消息,而是创建了IoT中心消息,而中心又创建了服务总线消息,因此会话处理不受我们的控制。

如果没有服务总线队列的会话功能,如何处理这种模式?

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)