azure-servicebus-queues相关内容

Azure Service Bus队列或主题中的分区数量是否有限制?

official document中,每个命名空间最多允许100个分区队列。但是一个队列中允许的分区数有上限吗? 谢谢 推荐答案 谢谢Sajeetharan, 基于MS DOC 目前,Service Bus允许多达100个分区队列或主题 每个命名空间。每个分区的队列或主题都计入 每个命名空间10,000个实体的配额(不适用于Premium 层)。 没有单据。如here ..

对同一消息多次调用Azure函数的服务总线队列触发器

我有两个Azure功能,一个是http功能,另一个是队列触发功能。在http函数中,我向队列添加消息,并在队列中触发处理它。当我在队列中记录消息时,触发有时会多次触发相同的消息?原因是什么? 提前谢谢 推荐答案 可能有几个原因。不看代码,我的猜测如下: 基于HTTP的函数被多次调用。可以通过分配从邮件属性派生的唯一邮件ID,然后使用ASB的本机重复数据消除来进行验证。 基 ..

Azure Logic/Service Bus队列-在队列中接收到消息时,同时使用&的消息数量是多少?

我的设置: 我已创建了一个未启用会话的Azure Service Bus队列 我有一个使用When a message is received in a queue (peek-lock)触发器创建的Azure Logic App 触发器间隔15 seconds 我的结果: 我正在以快于15秒的速度将邮件放入队列 我的Azure Logic应用程序触发器一次接收多条队列消息 ..
发布时间:2022-08-16 09:38:01 其他开发

优化批处理模式下从Azure Service Bus接收消息

我们有一个包含200K+消息的服务总线(标准计划)队列。我们希望以2K-5K的大小从服务总线读取消息,并使用Azure函数(每30分钟)将其批量插入到SQL DB中。 大多数情况下,ReceiveMessagesAsync会返回几百条消息,有时会达到一位数。我确实理解MaxMessages参数不能保证消息计数,但我仍然想知道是否有任何方法可以优化它,使其返回至少50%的最大消息计数。 现在 ..

MasstranSite-长时间运行的流程和即时响应

我正在使用具有Azure Service Bus的MasstranSite,我希望实现的是从API调用Bus,其中的一些请求将触发较长的进程,但也会立即获得已收到请求的响应。 实现这一目标的最佳方式是什么? 我应该将JobConsumer和GetResponse与JobSubmissionAccept一起使用,还是有更好的选择? 推荐答案 如果您的使用者需要很长时间,通常超过五分 ..

MessageLockLostException:提供的锁无效。锁定已过期,或消息已从队列中删除

我正在尝试使用服务总线队列触发器从队列中消费消息,并执行一些需要一些时间才能完成的工作。我不希望在处理消息时其他处理器拾取该消息。我在Host.json中有以下配置。当我从等待接收者的队列收到消息时。CompleteAsync(LockToken); 我收到一个异常&提供的锁无效。锁定已过期,或者该邮件已从队列中删除。"; "serviceBus": { "prefetchCo ..

Azure Service Bus中每个实体的最大会话数

Azure Service Bus允许使用会话实体(队列和主题),我们使用它们来保持由同一使用者进行批处理(如果我们从生产者发送批处理,则它必须由同一使用者服务处理)。我找不到任何关于每个实体允许的最大会话数量的建议,我们目前有4个会话用于1000,000条消息,我想知道我们是否可以增加这个数量。如果可以,我的案例的最大可能价值是多少? 有关我的进程的简短信息: *要发送给ASB实体的1,000 ..
发布时间:2022-05-19 16:51:52 其他开发

批量向ServiceBus队列发送消息时发生错误异常

我正在尝试成批地向服务总线队列发送几条消息。我正在使用QueueClient的SendBatch方法。 我在此操作过程中收到FaultException: 使用不同的SessionID、PartitionKey或 具有分区的实体不支持MessageID 已启用重复检测。 该异常的消息很简单,我会尝试修复它,但有时会奏效,不会引发任何异常。 所以它有时会抛出异常,有时会起作用。我 ..
发布时间:2022-05-19 16:41:48 C#/.NET

提供的锁无效

我使用的是Microsoft Azure服务总线队列,每当我在本地运行它时,都会收到以下两个错误: 无法从文件确定项目语言。请使用[--cSharp、--javascript、--tyescript、--java、--python、--PowerShell]中的一个 Microsoft.Azure.ServiceBus.MessageLockLostException:提供的锁无效。锁 ..
发布时间:2022-05-19 15:07:52 其他开发

完成或放弃邮件时发生Azure.Messaging.ServiceBus错误

SOM我目前正在考虑将我们非常简单的Service Bus服务更新到最新版本(Asure.Messaging.Servicebus),我在这里遇到了一个较小的问题。 问题是,我希望通过将消息委托回服务类中的方法来处理作业,从而手动完成或放弃接收到的或达到峰值的消息。 这是我目前为止的简单类,由一个接口公开。 using myProject.Interfaces; using my ..

一次性清除 Azure 服务总线队列

我们在项目中使用服务总线队列.当管理员选择清除队列时,我们需要一个从队列中删除所有消息的功能.我在网上搜索,但找不到在 QueueClient 类中执行此操作的任何函数. 我是否必须将所有消息一一弹出,然后将它们标记为完成以清除队列,还是有更好的方法? QueueClient queueClient = _messagingFactory.CreateQueueClient(queueNa ..
发布时间:2022-01-21 11:55:27 C#/.NET

Azure 服务总线中的消息锁定和锁定续订如何工作?

试图确定窥视锁在服务总线中的工作方式时,我感到有些困惑.特别是我将 Microsoft.Azure.ServiceBus 与 Azure Functions 和 ServiceBusTrigger 一起使用. 据我所知,消息被锁定的时间是在队列本身上设置的,默认为 30 秒,尽管它可以设置为最长 5 分钟. 当从队列中窥视消息时,此锁将启动. 然后在 Extensions:Ser ..

Azure Function Service Bus 触发器的触发次数多于队列中的消息

我有两个服务总线队列和 Azure 服务总线队列触发器. 该函数从队列中读取 1000 条消息并将它们转发给另一个(用于测试)发布到 Azure(计划消费)时,即使队列中只有 1000 条消息,我也会获得 1030 多个函数命中.我认为这与函数实例的数量有关. 问:如何对 1 个函数实例只处理 1 个唯一消息一次? [FunctionName("Function1")]公共静态异 ..

获取“amqp:内部错误"使用 AMQP、rhea 和 Node 从 Azure 服务总线队列查看消息时

几天前我问了同样的问题:无法“窥视";使用 AMQP 和 Node 来自 Azure 服务总线队列的消息.我再次问同样的问题,但有一些不同(因此,请不要将此问题标记为另一个问题的重复): 在上一个问题中,我使用了 nodeamqp10 库,但是根据 Github 页面上针对该库的一些评论,我最终使用了 rhea 而不是 nodeamqp10 库. 在 Azure 服务总线团队的帮助下,我取 ..

通过代码创建 Azure ServiceBus 队列

抱歉,我是 Azure 的新手.我使用这个 教程. 我可以从队列中读写.问题是,要部署到下一个环境,我必须更新 ARM 模板以添加新队列或在代码中创建队列.我无法在下一个环境中通过门户创建队列. 我选择了后者:检查队列是否存在并通过代码根据需要创建.我已经为此实现了 CloudQueueClient(在 Microsoft.WindowsAzure.Storage.Queue 命名空间 ..
发布时间:2021-11-24 16:31:11 C#/.NET