如何获取Azure Service Bus队列中的死信消息计数?
如何获取Azure Service Bus队列中的死信消息计数? 我可以像这样获得队列中的计数... var ns = NamespaceManager.CreateFromConnectionString(sbConnectionString); var queue = ns.GetQueue(queueName); var count = queue.MessageCount;
..
azure-servicebus-queues相关内容
Azure Service Bus客户端可以连接到ActiveMQ AMQP队列吗?
Microsoft Azure Service Bus 3.1.7 API可以用于连接到ActiveMQ AMQP队列，还是仅用于连接到Service Bus AMQP队列吗? 解决方案 否.它仅适用于SB. AMQP .NET lite 是与SB或任何其他代理合作的解决方案.
..
Azure服务总线队列:我可以管理/取消计划的消息吗?
如果我日后使用以下方式安排邮件: d = datetime.utcnow() + timedelta(minutes=5) task = {"some": "object"} sbs.send_queue_message( qn, Message( task, broker_properties={'ScheduledEnqueueTime
..
如何通过端口80将消息发送到Azure Service Bus?
据我所知，Azure服务总线使用端口9350、9353等发送消息.在我的组织中，由于防火墙策略的原因，我们无法打开这些端口.因此，每当我尝试将消息发送到Azure中的队列时，我都会收到错误消息 主机mycloudsevice.servicebus.windows.net没有DNS条目." 有没有办法通过端口80/443发送这些消息，因为它们始终处于打开状态? 让我知道我是否可以进
..
如何窥探死信
很难找到有关将所有消息放入死信队列并进行窥视的良好文档. 我有一个Azure Servicebus队列，我所能找到的都是关于Azure Servicebus主题的. 有人可以帮助我提供快速指南吗? 解决方案 死信队列是将毒物消息移动到的辅助子队列. 对于Azure Servicebus队列，DLQ的标准路径为queuePath/$DeadLetterQueue. 因此，您
..
Azure Service Bus重试策略不会更改行为
我正在尝试了解Azure Service Bus上的重试策略，但是它没有按我期望的方式工作.我有以下代码，它们既侦听消息，又将消息发送到特定的天蓝色队列. using System; using Microsoft.ServiceBus; using Microsoft.ServiceBus.Messaging; namespace ServiceBusTester { class
..
Azure Service Bus不断抛出MessageLockLostExceptions
在处理邮件时，我总是得到MessageLockLostExceptions. 我正在将Microsoft.Azure.ServiceBus 3.2.0与.NET Core 2.1一起使用. 我有一个LockDuration设置为30秒的队列，其中已经包含许多要处理的消息. 我从 现在，我想通过添加Task.Delay(10_000)模拟运行时间稍长的消息处理任务(但仍在LockDura
..
Azure服务总线实体吞吐量
根据本文: https://azure.microsoft.com/en ...，服务总线每个队列/主题每秒最多可处理2000条消息.本文: https://azure.microsoft.com/en ...说“这意味着分区队列或主题的整体吞吐量不再受单个消息代理或消息传递存储的性能的限制."如果我们创建分区队列/主题，我相信它会在内部创建16个分区.我的问题是:分区队列/主题的吞吐量是否线性增
..
具有多个侦听器的天蓝色服务总线队列/具有队列的竞争消费者
从理论上讲，相对于消息和接收者，蔚蓝服务总线队列看起来是一对一的. 只是想知道队列中是否可以有多个侦听器. 如果为1:1，是否意味着要实现竞争性的消费者模式，我们就不能使用队列，而主题是唯一的选择吗? 解决方案 队列和主题之间有很大的区别:对于队列，每条消息仅由 1个使用者接收.有了主题，订阅该主题的每个消费者都会收到每条消息(尽管仍有过滤的余地...).如果您的方案要求每条消息仅由
..
Azure服务总线"ReceiveAsync"
是否有一种使用Microsoft.Azure.ServiceBus包的方式来等待您当前的线程从队列中接收消息? 这可能是我的理解存在问题，并且希望以不打算使用的方式使用该技术，但是我想做的是结合 一些伪代码在这里: // send message(s) that will be consumed by other processes / applications, and by
..
在天蓝色的辅助角色中使用QueueClient.OnMessage
我有一个Azure工作人员角色，负责检查4个服务总线队列.当前，我只是手动检查队列的循环方法. while(true) { //loop through my queues to check for messages } Azure SDK 2.0附带了侦听消息而不是轮询消息的功能.但是我看到的每个示例都使用带有Console.ReadKey()的控制台应用程序.是否有办法让工作
..
Azure Logic App服务总线消息内容
我有一个由服务总线触发的逻辑应用程序.消息内容不可用，因为它只是随机字符.我怀疑也许需要对其进行解析，但是目前尚不清楚该怎么做. 我有以下内容: 没有足够的声誉来添加图像-但是来自Azure的屏幕截图 "Insert_Entity": { "inputs": { "body": { "Pa
..
如何使用路由查询将消息路由到服务总线队列?
我有一个IoT中心，该中心具有连接的设备，可以发送遥测消息.我想分别从每个设备读取消息，因此我决定为每个设备创建一个不同的终结点.为了对消息进行排序，我将路由与查询一起使用，但是当我向路由添加查询规则时，消息将停止到达端点.连接的设备使用MQTT. 以下是屏幕截图: 端点 路线 到MyEndpoint路线 解决方案 您的查询表达式正确. 但是请确保您按如下所示设置内容
..
使用Logic Apps在无服务器Azure功能上进行有序消息处理
我需要在Azure上处理传入消息.每条消息都将与特定实体相关联(例如，通过EntityId属性)，并且属于同一实体的消息必须相对于彼此按顺序进行处理.同时，我将保留Azure Functions的无服务器方面.如果我有1000个实体的稳定消息流，则我希望函数有1000个并发执行.我还没有找到一种干净的方法来实现这一目标.服务总线队列具有会话，这是我的要求的最接近的实现，但是Azure Functi
..
在Azure功能中按顺序处理服务总线消息(无并发调用)
我需要通过"Azure函数"读取和处理来自Azure Service Bus队列的消息.消息应该以正确的顺序处理，所以我需要避免并发调用. 为此，我使用Azure Function服务总线触发器(它是队列的唯一订阅者).根据文档，我将"servicebus/maxConcurrentCalls"(在host.json中)配置为1.在此之上，我用"Singleton"属性装饰了该函数. 除了所
..
Azure Functions和DocumentDB触发器
是否可以在写入DocumentDB时指定DocumentDB将触发触发器? 我有一个Azure函数，可将JSON消息从Service Bus队列中拉出，并将其放入DocumentDB中，如下所示: using System; using System.Threading.Tasks; public static string Run(string myQueueItem, Trace
..
Azure服务总线模拟器
我正在开发使用服务总线队列的WebJob，但是我没有Azure帐户. 是否存在一些用于测试Webjob的Service Bus模拟器? 我需要接受队列输入来模拟[ServiceBusTrigger] 解决方案 据我所知，没有服务总线模拟器. 在 https://feedback.azure.com/forums/216926-service-bus/suggestions/25655
..
为什么要使用QueueClient与MessageFactory?
在Azure Service Bus中，可以使用QueueClient和MessageFactory发送代理消息.我想知道您为什么要在另一个上使用一个. 解决方案 Azure Service Bus提供了不同的发送/接收消息的方法. 您可以使用QueueClient向队列发送消息或从队列接收消息. 您可以使用TopicClient将消息发送到主题 您可以使用Subscriptio
..
如何访问Azure订阅上的死信子队列?
当我使用以下内容时: var deadLetterPath = SubscriptionClient.FormatDeadLetterPath(topicPath,subName); var client = SubscriptionClient.CreateFromConnectionString(connectionString, deadLetterPath, subName);
..
WebJob和SignalR集线器之间的通信
我有以下情况: 我有一个天蓝色的webjob(用于发送邮件)，需要在我的Web应用程序中检查webjob的进度. 我正在使用SignalR与服务器上的客户端进行通信. 当我要发送电子邮件时，我在队列中推送一条消息，而天蓝色的webjob会完成他的工作. 问题是，如何将Webjob的进度传达给客户?最初，我的想法是从Webjob推送消息，因此Hub可以从队列中读取它.然后，我将从集线
..