问题标签 [azure-servicebus-subscriptions]

我正在尝试使用 C# Nest 更新弹性搜索中的文档。我有 Azure 服务总线触发功能，它提供要更新的数据。以下是我为更新文档而执行的步骤。

1. 通过 ID 从 Elastic Search 索引中获取记录
2. 进行更改
3. 按 ID 更新记录

如果我使用单个消息进行测试，则逻辑工作正常。在并发请求的情况下，弹性搜索正在重新调整空响应。

下面是 servicebus 消息和 Nest 逻辑的详细信息。

信息 ：

ID 数据待更新 12345678 XXXXXXXXXXXXXXXX

商业逻辑 ：

如果我一次处理 10000 条记录，那么大约有 500 到 1000 条记录返回 null（即使带有 Id 的记录也存在于 ES 索引上）。

我需要一些帮助来处理具有快速处理和更少故障的并发请求。

注意：任何消息中的 Id 都不为 null 或为空。

我面临一个奇怪的场景，我有一个 SB 主题，它有两个订阅 Sub1 和 Sub1。每个订阅我都有两个听众（除了我的没有其他听众） Sub1 => Listener1 Sub2 => Listener2

一直看到 Listener2/1 看到 msg 而另一个完全错过的问题。没有例外，没有死信等。它是否有可能发生在 SB 级别？我可以在这里检查什么以进行故障排除？

我们以这种方式将 MassTransit 配置为使用 Azure 服务总线：

我们如何为 MassTransit 自动创建的所有订阅设置订阅属性，例如 EnableDeadLetteringOnMessageExpiration？

谢谢，彼得

更新

我已经尝试过（EnableDeadLetteringOnMessageExpiration），但 Azure 服务总线中的订阅未启用死信选项（我们首先删除了所有主题和订阅，以便它们是新创建的）：

我正在尝试使用 ServiceBusProcessorClient Azure 服务总线消息传递 jar (azure-messaging-servicebus-7.1.0)。我 defer 在 ServiceBusReceivedMessageContext . 但没有看到任何 API 来检索延迟消息。 ServiceBusProcessorClient 接受 Consumer 要处理的消息。该消费者可以接收延迟消息吗？

我提到这个通过订阅从我的 Azure 服务总线接收消息

我能够收到消息，但我会不断收到消息，直到我手动终止程序

我有一个超时选项，并且只想在超时之前接收消息。

如果您可以解释以下代码的工作原理以及如何修改以下代码以接收特定时间范围内的消息并在达到超时后停止接收，这将很有帮助。

我想使用 Azure 服务总线的自动转发功能。我有一个名为“旅行”的主题，并有一个名为“测试”的订阅。

我已启用自动转发并将消息转发到另一个名为“trip_elaborated”的主题。这工作正常。但是，它不会等待消息完成然后自动转发到另一个主题。

例如，“测试”订阅需要 30 秒来处理消息，并且在完成之前它会将消息转发到“trip_elaborated”主题。我希望这个操作同步进行。

是否需要任何配置？或者任何其他方式来实现这种场景？

我更愿意使用服务总线资源管理器来管理它（无需在使用代码的消费者中明确执行）。

我正在使用以下库通过 Java 应用程序连接到我的 Azure 服务总线

我能够成功连接到服务总线。但是我的控制台充满了我想关闭的 Azure 消息服务总线日志

我无法删除项目中的记录器实现，因为我需要其他模块

以下是我收到的示例日志

如何仅关闭 Azure 服务总线日志？

给定一个我有权访问并且可以在其中查看所有队列、主题和主题订阅的 Azure 服务总线，是否有一种简单的方法可以查看所有订阅将消息转发到给定队列？

我唯一可以编写代码来遍历服务总线中所有主题的订阅并比较“转发到”设置以查看它是否与我感兴趣的队列匹配吗？

我需要一起处理同一组消息，为此，我尝试了 Azure Service Bus Sessions Enabled 功能。为了测试这一点，我创建了一个非常简单的应用程序，一条消息在队列中成功提交，但是，当尝试在“ReceiveSessionMessage”函数中接收消息时，没有返回消息会话并且程序在此行之后退出。

我无法找出确切的根本原因，任何帮助将不胜感激。谢谢

[var messageSession = 等待 sessionClient.AcceptMessageSessionAsync();]

程序

控制台输出

如何在我的 Ruby 应用程序中集成 Azure 服务总线以发送和接收来自主题的消息？