当前位置: 首页 > 知识库问答 >
问题:

Azure Logic App中服务总线连接器的消息处理策略

洪楷
2023-03-14

正如我们从留档中知道的,这个连接器每次运行可以处理20条消息。但是我们在这里看到的。

我们没有两次运行20/20,而是三次运行1/20/19

为什么会这样?我在文档中找不到解释?

共有3个答案

邹华池
2023-03-14

logic应用程序不会等待20条消息建立,因为它不知道是否还会有更多消息。因此,它会立即触发第一条消息。此时,没有其他消息可供处理。

根据屏幕截图中的时间戳,会发生以下情况:

  1. 您可以设置逻辑应用程序、配置触发器等。
阎昌勋
2023-03-14

我想让您知道20是连接器中的默认计数,您可以增加计数(最大消息计数)。它可能无法完全解决您面临的问题,但至少可以减少执行的次数。

要修复第一个消息问题,请考虑使用批处理接收器。

楚浩然
2023-03-14

逻辑应用程序服务总线不保证批处理以实现此使用批处理接收器

看起来逻辑应用程序将被第一条消息触发,并尝试预取下一个20个(默认大小)项,并在下一个项中执行该操作。

一些触发器,例如当一个或多个消息到达队列(自动完成)触发器,可以返回一个或多个消息。当这些触发器触发时,它们返回一个和触发器的最大消息计数属性指定的消息数之间的值。

https://docs.microsoft.com/en-us/azure/connectors/connectors-create-api-servicebus

 类似资料:
  • 我对Azure服务总线队列还比较陌生,正在构建一个项目,该项目需要按照消息到达的顺序(FIFO)处理队列中的消息。 使用微软的文档,我能够理解这一部分。据我所知,我需要为队列打开会话? 我所面临的困难是确定对队列执行以下一组有序任务的最佳方法/服务堆栈。 首先,让我们假设我们有一个基于先进先出的服务总线队列,它有n个消息。我怎么可能: 从队列中拾取第一条消息。 使用Azure函数处理消息。 将有效

  • 参考https://github.com/Azure/azure-service-bus/tree/master/samples/dotnet/gettingstart/microsoft.Azure.servicebus/basicsendreceiveusingtopicsubscriptionclient,我了解Azure服务总线主题的一般工作方式,我的问题更多地是关于它实际上是如何工作的。

  • 我在Azure Service Bus中使用代理消息传递(主题/订阅),我很好奇如何(或者是否)使用SSL保护通信。

  • 我们目前正在利用Azure服务总线来处理来自应用程序的各种消息。 我想知道实时处理这些消息的最佳方式是什么? 有没有一种方法可以在消息放入队列时自动执行脚本? 我只是在想,一定有比让一个单独的应用程序每分钟/30秒检查一次队列更好的方法。 谢谢各位

  • 我在Azure中托管了两个云服务辅助角色,一个使用NServiceBus(Azure服务总线传输)消耗消息,另一个生成消息。 昨天,我部署了一个新版本的生产者工作者角色,而队列中仍然有大量消息,因为我们正在处理早上遗留下来的大量消息。当生产者启动时,它似乎已经清空(或者可能重新创建)队列,许多重要的生产消息丢失。这似乎很奇怪,但日志显示,大约在生产者角色启动时,消费者没有处理进一步的消息,我们知道

  • 我想在异步模式下使用Azure服务总线客户端(Microsoft.ServiceBus.dll),但不知道如何处理取消。例如,方法不采取任何,因此考虑到只要队列中没有消息,此方法就不会返回,如果要取下接收循环,我如何优雅地中断它呢? 多谢.