azure-servicebus-queues相关内容

使用REST API将消息发送到.Net Core Core中的Azure服务总线队列

我想向.Net Core中的Azure Service Bus队列发送消息,但WindowsAzure.ServiceBus包与.Net Core不兼容. 任何人都可以告诉我如何使用REST API将消息发送到队列吗? 解决方案 当前客户端与.NET Core不兼容,即新客户端,正在进行中,是100%兼容的.预发行软件包将在4月3日提供,状态可以通过 ..

如何在ARM模板中为Service Bus Logic App操作设置连接字符串?

我正尝试部署Azure逻辑应用程序,其中包括使用ARM模板在服务总线上发送消息的操作. 除了部署Logic App外,ARM模板还部署了服务总线命名空间,一个队列和两个AuthorizationRule(一个用于发送,一个用于侦听). 我想动态设置“发送服务总线消息"操作的连接信息,以使用为支持发送的AuthorizationRule生成的连接字符串. 当我在门户网站编辑器中创建 ..

如何从"PeekLock"中的Azure Service Bus队列中获取消息AMQP模式?

我们正在尝试在Node应用程序中使用Azure Service Bus. 我们的要求是从队列中提取多条消息. 由于Azure Node的SDK不支持批量检索,因此我们决定使用AMQP.虽然我们可以按照此处所述使用“查看邮件"来获取邮件(我们注意到的是,一旦获取消息,它们就会从队列中删除.我想知道是否有人了解我们如何使用AMQP和Node以"PeekLock"模式获取消息.对于AMQP,我们使 ..
发布时间:2020-08-24 01:57:29 其他开发

得到"amqp:内部错误".使用AMQP,rhea和Node从Azure Service Bus队列中查看消息时

几天前我问了同样的问题:从Azure Service Bus队列发送消息.我再次问相同的问题,但有一些区别(因此,请不要将此问题标记为其他问题的重复项): 在上一个问题中,我正在使用nodeamqp10库,但是基于该库在Github页面上的一些评论,我最终使用了 rhea 而不是nodeamqp10库. 在Azure Service Bus团队的一些帮助下,我取得了一些进展,现在我从Azu ..

通过代码创建Azure ServiceBus队列

抱歉,我是Azure的新手.我使用教程. 我可以从队列中读写,确定.问题是,要部署到下一个环境,我必须更新ARM模板以添加新队列或在代码中创建队列.我无法在下一个环境中通过门户创建队列. 我选择了后者:检查队列是否存在,并通过代码根据需要创建.我已经有一个我希望它会如此简单,但事实并非如此.我正在努力寻找一种创建 NamespaceManager 和任何人都可以指出我如何实现这一目标的 ..
发布时间:2020-08-19 19:17:03 C#/.NET

Azure Service Bus使用消息内容或消息头数据调度消息取消

我想使用消息内容取消服务总线queue/topic中的计划消息. 例如:queue/topic中的预定消息将类似于{UserName:'Scott', Test: 'This is test msg'} 我想使用UserName 取消计划消息 注意:我没有保存取消令牌,可以用来取消计划的消息. 解决方案 AFAIK,无法基于用户属性取消计划的消息.您唯一可以取消预定消息的方 ..

侦听队列(事件驱动的无轮询)服务总线/存储队列

我试图弄清楚如何监听队列中的事件(尤其是入队事件)。 说我有一个控制台应用程序和一个服务总线队列/主题,如何连接到队列并等待新消息? 我正在尝试在没有而实现(真)且不间断轮询的情况下实现此目标 我不想使用轮询的原因是我了解它的泛滥服务器上有请求,我需要一个可以在高负载下工作的解决方案。 谢谢。 我给出了一个非常简单的示例来说明问题的简单性,但是我的实际情况却有些复杂: ..

MassTransit和MaxConcurrentCalls行为不符合预期吗?

我将MassTransit用作消息传递框架,并在Azure Service Bus上运行.我正在WebJob内部运行MassTransit(尽管我认为这并不重要) 现在,我正试图让MassTransit同时处理多条消息,因为我现在正在处理需要花费一段时间才能处理的消息.因此,为了提高性能,我不希望每条消息都一个接一个地处理. 我尝试将MaxConcurrentCalls设置为,例如30 ..

如何使用Azure Pipelines为kubernetes设置自动缩放比例(在同一节点上并向外扩展)?

我想在Azure Pipelines中设置自动缩放功能,以使用Kubernetes部署容器.如果要按以下规则自动缩放,怎么办: 取决于编号. ServiceBus消息队列中的消息数量 它将首先在节点内部扩展(更好地设置节点中的最大Pod,因为它取决于线程号?) 如果在一个节点中达到最大Pod,则它将向外扩展以使用另一个节点(也可以扩展为使用该节点的最大Pod吗?即1个节点3个Pod,2个 ..

brokeredmessage微软服务总线队列ReceiveBatch没有获得所有死信消息

我测试了死信队列与微软服务总线的项目。我送26消息(代表字母)和我使用一个程序,接到消息时,随机把他们有的在死信队列。消息总是从死信队列偷看模式阅读,所以一旦他们到达那里,他们呆在那里。跑了几次后,所有26个邮件将在死信队列,并始终保持在那里。 然而,阅读它们的时候,有时只有少数(如6 。)阅读,有时所有26 我用命令: const int的maxToRead = 200; / ..
发布时间:2016-10-04 16:12:37 C#/.NET

如何序列化观测量到云和背部

我需要拆分处理顺序(如在这个问题如何组织数据处理器序列与.NET RX )到Azure的环境的一些计算单位。结果 的想法是序列观测序列的Azure队列(或服务总线)和反序列化回来。结果 。如果生产者或消费者失败其他一方应该可以继续生产/消费。 任何人都可以提出一个优雅的方式这样做,有什么用(Azure的队列或者服务总线)?结果 有没有人用TCP观测提供商 - http://rxx.co ..

Azure的服务总线认购死信

我到处找的信息,这一点,但似乎无法找到我要找的。 我有一个蔚蓝的话题,一个订阅。 有关认购的处理失败的一些消息,他们已经被提上了死信队列中。 我可以访问的消息,但我在为如何恢复他们的损失。 我不希望创建邮件的副本,并将其发送的话题。我特别希望将它移动到它来自认购队列中。 有没有办法做到这一点? 解决方案 我不知道这是可能的。 我们主要是做处理&安培;恢复消息,是使用deferi ..

Azure的WebJobs ServiceBus返回例外:发现授权范围内2 DNS索赔

我试图读取使用Azure的WebJob蔚蓝ServiceBus队列中的消息,但它的投掷和异常: 未处理的异常:System.InvalidOperationException:发现在授权范围内2 DNS索赔。 我给自己定名为“AzureWebJobsServiceBus”,“AzureWebJobsDashboard”和“AzureWebJobsStorage”正确的连接字符串 该WebJo ..

Windows Azure的MessageLockLostException

我在使用Azure的消息总线队列的问题。 我有MessageLockLostException抛出该请求的操作没有的0时01分10秒的超时时间分配内完成。分配给该操作的时间可能已经较长超时的一部分。 我已经把我的队列到ReceiveMode.PeekLock。 我也检查 如果(message.LockedUntilUtc.Minute< = 1) message.RenewL ..
发布时间:2016-07-29 17:52:00 C#/.NET

确定有多少消息是对Azure的服务总线队列

我知道有一种方法来确定的Azure队列(Store帐户)消息(或近似数)的数量;然而,有一种方法来查询待处理的邮件上的Azure的服务总线的排队?数 解决方案 VAR nsmgr = Microsoft.ServiceBus.NamespaceManager.CreateFromConnectionString(的connectionString); 长计数= nsmgr.GetQueue ..

服务总线 - 辛格尔顿连接类?

我试图弄清楚什么是使用服务总线从Web-API的最佳做法。 我读过,重新创造一个像QueueClient,SubscriptionClient等对象'是错误的做法,所以我需要重用的工厂和客户。 服务总线客户对象,如Microsoft.ServiceBus.Messaging.QueueClient或Microsoft.ServiceBus.Messaging.MessageSender,通 ..
发布时间:2016-07-29 17:19:47 C#/.NET