logic应用程序不会等待20条消息建立,因为它不知道是否还会有更多消息。因此,它会立即触发第一条消息。此时,没有其他消息可供处理。
根据屏幕截图中的时间戳,会发生以下情况:
我想让您知道20是连接器中的默认计数,您可以增加计数(最大消息计数)。它可能无法完全解决您面临的问题,但至少可以减少执行的次数。
要修复第一个消息问题,请考虑使用批处理接收器。
逻辑应用程序服务总线不保证批处理以实现此使用批处理接收器
看起来逻辑应用程序将被第一条消息触发,并尝试预取下一个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),但不知道如何处理取消。例如,方法不采取任何,因此考虑到只要队列中没有消息,此方法就不会返回,如果要取下接收循环,我如何优雅地中断它呢? 多谢.