问题标签 [azure-servicebus-subscriptions]

我正在编写一个实用程序来监视我们的 Azure 服务总线主题和订阅。

我可以获取主题详细信息，例如名称、排队消息数和死信消息数，但我想获取已处理的消息数。

这是我正在使用的代码：

似乎GetSubscription不包含任何属性来获取处理的消息数。

有没有人尝试过这样做？

使用 Azure 服务消息总线主题和订阅。

创建了一个主题aaaa和订阅zzzsubscription- 会话感知。

使用以下代码向具有会话 ID 的主题发送消息：

使用以下代码从订阅中读取消息：

在该行获取以下异常 return subscriptionClient.completeAsync(message.getLockToken());：

使用以下版本的 Azure 服务总线 SDK：

编辑1：

如果我添加以下内容，则到上面的代码：

并将 onMessageAsync 中的返回更改为以下内容：

然后我得到以下错误。收到了一些消息，但我收到以下错误并且程序挂起：

通过将发送声明添加到只听策略解决了上述问题：https ://github.com/Azure/azure-service-bus-java/issues/110

和

我有一个主题订阅，其中包含我无法降低队列长度的会话。它似乎保持在 95 到 105 的恒定范围内，非常紧密。

我想知道这是否只是会话的产物，因为我们对同一主题的其他订阅，没有会话，设法轻松地坐在 10 以下。

消息速率不是特别高，大约每秒 50 条。

目前有 102 个长寿命会话。每个会话每 2 秒将看到 1 条消息。随着时间的推移，随着我们添加新的“频道”，将创建更多会话。

我能想到的最好解释是，虽然订阅队列长度约为 100，但当您将其标准化为会话数时，它实际上将其归零。

在主题订阅中使用会话时，这可能是预期的行为吗？

我正在尝试在 Azure 服务总线上的订阅上添加规则。消息的有效负载如下所示：

使用 New-AzureRMServiceBusRule 创建新规则时，当我尝试添加"body.type = 'payment'". 如果我只是使用"type = 'payment'"一切都很好，但我的客户使用的标准库会强制一切进入它自己的信封结构。

有没有办法在服务总线规则中解析 JSON 有效负载？

关于取消令牌，如何使用它来取消消息？如果我没有完成消息，它是否会自动取消（例如，稍后在有连接时重试）？我需要放弃它吗？取消令牌是否仅在 SubscriptionClient 上？

例如，当我使用 CloseAsync() 关闭连接时，会触发 cancelToken.IsCancellationRequested。

这是取消令牌的唯一用途。稍微了解如何使用取消令牌将非常有帮助。

在我当前的项目中，我有一个想法，即在主题订阅上使用过滤器/规则来自定义重试策略。

我从 Azure 函数中的主题收到一条消息，并尝试将其发送到远程服务。如果服务抛出 Timeout 异常，我想在消息中添加一个名为 PostponeUntil 且具有特定日期时间（例如一小时）的自定义属性，再次将其添加到主题中，然后使用订阅规则过滤掉这条消息，直到需要重试。是否可以使用 SqlFilter 做这样的事情：

如果没有，我所拥有的场景有哪些替代方案？

我们正在努力与服务总线集成。我们没有 azure 帐户，因此我们无法运行自己的服务器，但我们的客户端可以。

出于测试目的，是否有任何公开可用的服务总线主题可供我订阅并测试我们的代码？内容实际上并不重要，我们只是想确保我们的代码可以连接和读取消息。

如果这不可能，那么测试我们的 Azure 服务总线订阅代码的方法是什么？我们需要开一个azure帐户吗？

谢谢！

我订阅了一个主题，发件人设置了两个用户属性“分类”和“子分类”。我想过滤分类设置为 1 的消息。我尝试添加以下 SqlFilter。

SqlFilter("分类='1'")

它不起作用。无论“分类”属性如何，我仍然会收到所有消息。

我正在使用 Microsoft.Azure.ServiceBus 命名空间中的订阅客户端。

我可以在 Azure Functions 1.0 中实现类似于以下内容的内容，但现在它似乎在 2.0中CompleteAsync()并且AbandonAsync()不再可用。

是否已将控制权交给了Peek Lock 的 Azure 函数默认值？

我想创建一个满足以下要求的 Azure 函数：

• 触发 HTTP 请求
• 查看 Azure 服务总线订阅并根据 HTTP 请求中指定的一组筛选器获取下一条消息。