问题标签 [azure-servicebus-topics]

如何在主题/订阅的 SqlFilter 中使用 DateTime？

我有这个消息：

我也有这个 SqlFilter：

不幸的是，这不起作用。

How do I subscribe to a Microsoft Azure topic? What are the ways in which I can subscribe?

I do not have any control on the topic creation and messages sent to the topic, I need to subscribe to the topic and get the messages from the topic

The preferred option is from TIBCO, is it possible? How do I go about it? I am using Tibco BW. If not tibco, is it possible to build a Java application for the same?

Couldn't find much help on google with respect to the implementation using Tibco. Any pointers on the approach and possibility will be really helpful

我正在尝试为服务总线瞬态错误实施重试策略。我希望我的系统像 1s、2s、4s、8s、16s、32s、64s、128s 一样以指数方式尝试。

这看起来对吗？该政策是否会影响系统性能？

I am subscribed to an Azure Service Bus Topic and I am trying to retrieve objects sent from my Python client. But in my receiving end all I get is something like this:

I have tried receiving in python and in .NET. Here is a dummy code of what I have tried:

Receiving dummy code in C#:

How can I retrieve the User object (the user_id and name) that was sent by the sender?

我们在一个 azure 网站上托管了一项工作，该工作从主题订阅中读取条目。当我们只有一个实例来托管网站时，一切正常。一旦我们扩展到多个实例，我们就会观察到消息的处理次数与我们拥有的实例一样多。每个实例都指向同一个订阅。根据我们阅读的内容，一旦该项目被阅读，它将无法用于任何其他进程。重复处理发生在同一个实例中，这意味着如果我们有两个实例，则该项目在其中一个实例中被处理两次，它不会被拆分。

我们做事的方式可能有什么问题？这就是我们如何继续配置与队列的连接，如果订阅不存在，则创建它：

处理主题项的代码示例：

此方法在 Function 静态类中，我使用的是 azure web job sdk。

每当 azure 网站扩展到多个实例时，所有实例都共享相同的配置。

我有一个多实例应用程序，我正在使用服务总线事件中心将一些消息放入其中并广播到所有其他实例，将消息发送到所有实例的条件是每个实例都需要位于单独的消费者组中否则一个实例将获取消息并将其删除，因此其他实例将不会收到消息，所以我的解决方案是首先每个实例创建它自己的消费者组，然后收听事件中心，但这里的问题是我由于实例崩溃，一段时间后会有很多消费者组未使用，我的问题是：是否可以检测并获取所有未使用的消费者组以删除主题？

PS：我也尝试使用主题/订阅，效果很好，但我有同样的问题，只需通过订阅替换上面的消费者组:)。

我有一个名为“AZTopic”的 Azure 主题，并且我有一个添加了三个规则描述的订阅。规则描述具有基于属性优先级的 sql 过滤器。当我尝试从订阅访问数据时，我得到 null 作为代理消息。

这是我的订阅创建代码

这是我的消息阅读代码

我在使用服务总线配置管理器加入现有农场时遇到问题。这发生在配置过程窗口中：

未找到组 WindowsFabricAdministrators。

我有 service bus1.1 和 Windows 10 家庭高级版。我浏览了很多博客将 Fabric 主机服务帐户添加到其他组，但在 Windows 10 的家庭高级版中，我看不到用户和组。

任何人都有任何想法，请提出我所缺少的并可以做些什么来使它工作。

我正在使用 azure 服务总线主题和订阅来处理消息。Windows 应用程序使用 api 获取消息。收到消息时，我使用 peek-lock 5 分钟。现在，如果假设 Windows 应用程序从 azure 获取消息并且在获取它之后应用程序崩溃。现在，当我再次打开应用程序时，消息没有从 api 获取。这是因为消息被锁定 5 分钟。当它被 azure 自动解锁时，我可以再次从 azure 获取消息。

由于崩溃，我无法从 azure 解锁、锁定消息。

那么如何在不等待azure自动解锁的情况下快速再次获取消息。因此，如果由于某种原因应用程序崩溃，那么我可以在应用程序启动时再次快速收到消息。

请帮助我如何解决这个问题。

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

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

这是我正在使用的代码：

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

有没有人尝试过这样做？