问题标签 [azure-servicebus-topics]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
2 回答
394 浏览

azureservicebus - Azure服务总线,创建客户端时间长

我正在尝试使用 Azure 服务总线进行一些发布/订阅。一切正常,但是当我尝试从连接字符串创建客户端时,连接需要很长时间。创建客户端大约需要 22 秒。

这就是它的完成方式。

建立第一个连接后,创建一个新客户端需要 2 毫秒。所以我猜大部分时间是创建一个到azure的连接并验证安全上下文。

我的问题是,其他人都这么慢吗?(如果不是,那么我猜是我们的网络设置让它变慢了)是否有另一种方法可以更快地连接和创建客户端?

最好的问候马格努斯

0 投票
1 回答
1999 浏览

azure - 发送到服务总线时的 OperationCanceledException

我在向主题队列发送消息时收到 OperationCanceledException(我在 Azure 函数中运行我的代码)。我正在使用的版本是:“WindowsAzure.ServiceBus”:“4.1.1”(最新),我在进行负载测试时遇到此异常,这意味着在此服务总线中发送了许多消息(其中包含几个主题) . 有人告诉我使用重试机制:

但我认为这已经默认完成了,不是吗?

是否会在此处提供您的帮助 - 为什么我会收到此异常,我该怎么做才能解决此问题?

这是一个例外:

0 投票
1 回答
160 浏览

c# - 将类型绑定到 Webjob SDK 触发器

我正在使用 Webjob SDK 来提供 azure 服务总线。

它工作正常,现在我想开始参数化它的输入。

我一直在做:

现在我还想添加一个额外的参数:端点。像这样的东西:

我认为可以通过将 URI 类型绑定到配置,如下所示:

但这似乎不起作用。这甚至可能还是我必须制作自己的自定义触发器?

0 投票
2 回答
4505 浏览

c# - Azure 服务总线主题订阅者锁定过期异常

OnMessage我有一个 Web 作业,它通过注册一个回调来使用来自 Azure 服务总线主题的消息。消息锁定持续时间设置为30 秒锁定更新超时设置为60。由于此类作业需要超过30 秒来处理服务总线消息,因此会出现锁定过期异常。

现在,我已将消息锁定持续时间设置为超过锁定更新超时。但不知何故,它仍然抛出同样的异常。我也重新启动了我的网络作业,但仍然没有运气。

我尝试运行相同的 webjob使用来自不同主题的消息以及后来的设置,它工作正常。是否会出现这种行为,以及此设置更改通常会在多长时间后反映出来。

任何帮助都会很棒

0 投票
1 回答
2554 浏览

properties - Azure 服务总线主题订阅,能否拥有多个 sql-filter 属性?

只是关于 Azure 服务总线主题订阅的问题,是否可以将多个属性分配给单个订阅?

也可以为其中一个属性启用空值吗?

我想要做的是能够使用 azure 函数以某种方式过滤标识符上​​的消息,具体取决于它是否存在。

我无法仅通过队列消息来做到这一点,因为我找不到插入 som 类型的元数据的方法。

我的问题的另一个解决方案是单独的服务总线主题订阅,其中它的属性可以接受被设置并在两个不同的值之间转换,然后我可以过滤。

我想这样做的原因不是复制整个动作序列,而是在服务总线主题之后的动作中插入某种过滤功能。

- - - - - - - - - - 更新 - - - - - - - - - -

好的所以有点更新,我在这件事上取得了一些进展。与此有关的另一个问题是:

当我向带有属性的 servicebus 主题订阅发送 Brokered 消息时,例如:

message.Properties['id'] = "1";

是否可以通过某种方式访问​​该消息属性值?我知道以这种方式使用可能并不重要,但这将为我打开一扇新的大门。

0 投票
1 回答
2709 浏览

.net - Azure 服务总线主题分区

我正在尝试向一个主题发送一条消息,该主题是在选中启用重复检测启用分区选项的情况下创建的。我没有在我的实例上设置SessionIdPartitionKey属性。BrokeredMessage据此:_

如果队列或主题的 QueueDescription.RequiresDuplicateDetection 属性设置为 true 并且未设置 BrokeredMessage.SessionId 或 BrokeredMessage.PartitionKey 属性,则 BrokeredMessage.MessageId 属性用作分区键。

在我创建BrokeredMessageMessageId属性的实例后,它会自动初始化,所以我希望分区能够工作。但它没有:

Microsoft.Azure.WebJobs.Host.FunctionInvocationException:执行函数时出现异常:Functions.ProcessQueueMessage2Async ---> System.InvalidOperationException:需要为支持排序的分区主题设置所有代理消息的 SessionId,主题名称 = dev1-mtapp:主题:响应主题~255。TrackingId:5fbe5df2-8747-4053-ba79-c29a80e9d1ed_G25_B31, SystemTracker:dev1-mtapp:topic:response-topic~255

我哪里错了?

0 投票
1 回答
848 浏览

azure - Azure 服务总线:如何将超过 256KB 的消息发布到主题?

我是老派的 Windows Azure 架构师。使用服务总线主题将消息传递给辅助角色。

如何发布更多感谢 256KB 消息到订阅?我知道有一个高级服务总线允许 1MB 消息,但 1MB 限制也可能不够。

0 投票
1 回答
876 浏览

publish-subscribe - 具有生成名称的独占自动删除订阅的 Azure 服务总线主题

如何在不指定订阅名称的情况下创建主题并订阅多个独立订阅者,每个订阅者具有不同的订阅。如果订阅者断开连接,相应的订阅应该被自动移除。例如,这种情况可以使用 rabbitmq 服务器来实现,用于记录目的。https://www.rabbitmq.com/tutorials/tutorial-three-dotnet.html

在 .NET 客户端中,当我们不向 queueDeclare() 提供任何参数时,我们会创建一个具有生成名称的非持久、独占、自动删除队列。

如果不可能,我该如何包装.net客户端来实现这种情况?谢谢。

0 投票
1 回答
564 浏览

python - qpid proton url,用于从给定订阅(主题)接收消息

我想从服务总线读取订阅消息。我正在使用qpid-protonpython 库。我正在关注此链接以接收消息Proton-Python-Example-Simple-Receive。我正在传递此 url 以接收来自服务总线的消息 -

我收到以下错误 -ERROR:root:The messaging entity 'sb://mynamespace.servicebus.windows.net/sharedaccesskeyname=xxxxx/sharedaccesskey=xxxxxxxxxxxxx/python-test/subscriptions/allmessages' could not be found. TrackingId:c1e4a39edbd44040b2fd48a552d6ae2b_G2, SystemTracker:gateway6, Timestamp:7/19/2017 7:58:51 AM

这是因为上述 URL 的格式不正确。我在网上搜索过,没有提供这方面的适当文件。通过 qpid 读取订阅消息的正确 URL 格式是什么。

0 投票
2 回答
164 浏览

powershell - 如何阅读 Azure 服务总线主题名称中包含 /。例如:PowerShell 中的 xxx/t000

我正在使用 PowerShell 来阅读 Azure 服务总线主题。主题名称中包含一些特殊字符。例如。主题名称为 xxx/t000。

当我使用:

我收到错误:

操作返回无效状态码“未找到”

所以我预测主题名称中 / 的问题。有人可以帮助我了解如何阅读其中包含“/”的主题名称吗?