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

逻辑应用程序仅在超时前读取一些服务总线消息

屈昊天
2023-03-14

我有一个逻辑应用程序,它由EventGrid主题触发,但使用事件中传递的SessionId从服务总线队列读取消息。

服务总线peek读取在一个直到循环中完成,该循环在服务总线peek读取超时时退出。(我已在操作设置中将超时设置为30秒)。

我遇到的问题是,尽管队列已满,但在循环退出之前只读取了大约20条消息。为什么会这样?

共有1个答案

贲俊才
2023-03-14

@托马斯给了我最终到达那里的线索。

直到循环有超时和迭代次数的“限制”设置,我才知道。

单击“更改限制”链接将显示这些设置,以便可以覆盖它们。

 类似资料:
  • 我在Azure logic应用程序中处理xml消息时遇到问题。我读了不少关于类似问题的文章,但不知何故,它对我不起作用:-) 我的情况: 我从一个逻辑应用程序向服务总线发布一条xml消息。似乎只有当主题采用Base64编码时,才能将消息发送到主题。所以我用下面的: 请注意,内容已经有这种格式: 执行此操作后,我看到消息被传递到服务总线主题。Service Bus Explorer工具显示以下消息文

  • 我正在尝试创建一个小的Azure逻辑应用程序,它将有一些订单流。我将在服务总线队列中获取消息。我需要在logic app中获取消息,根据消息内容,我需要执行进一步的步骤。该消息还将包含订单数据。假设有条件逻辑,如果订单类型为“new”,我需要调用HTTP请求,其中我需要在POST请求中将消息数据作为正文内容传递。 我创建了一个服务总线队列,在逻辑应用程序中,添加了服务总线触发器,当服务总线队列中收

  • 我正在开发一个Azure逻辑应用,其中有一个服务总线窥视锁触发器。服务总线的消息锁定持续时间为5分钟。我希望每5分钟有一个自动更新令牌机制,以防逻辑应用实例需要超过5分钟,以便该过程可以继续,而无需释放锁,让另一个消费者将消息带走。 有什么方法可以通过Logic应用程序实现这一点吗?

  • 您好,我有一个关于逻辑应用程序和Azure服务总线队列的性能问题。 我有一个逻辑应用程序,看起来像这样: (注意:延迟是为了模拟一组连接器/操作,这些连接器/操作运行大约需要2秒钟,我还使用锁令牌和会话ID来完成消息和关闭会话) 它通过峰值锁定每秒轮询服务总线以获得高吞吐量,因为我的服务总线队列使用会话在流中启用FIFO排序。因此,我正在做的是,向我的服务总线发送大约2000条具有不同会话ID的消

  • 我正在尝试在我的逻辑应用程序中使用Service Bus Queue send操作,该应用程序向队列发送消息。逻辑应用程序运行时,操作返回此错误: 尽管在创建队列时,我没有启用自动转发。有什么帮助吗?

  • 我在Azure中的服务总线上有一个主题订阅,锁定持续时间为30秒,并且启用了会话。 我正在使用一个逻辑应用程序来使用峰值锁来获取主题的消息,因为我关心消息的处理顺序。我希望确保具有相同会话id的所有消息都按照它们添加到总线的顺序进行处理,即FIFO。 下面是一个简单的逻辑应用程序的截图,当一个消息到达时,它会被触发(使用5秒轮询的peek-lock),然后它会在完成消息之前等待15秒。