azureservicebus相关内容

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

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

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

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

Azure服务总线:消息队列中正在处理重复的消息

我在蔚蓝服务巴士上工作。实际上,我的服务总线队列正在处理一条消息3次。我的消息锁定时间是5分钟。每条消息最多处理2分钟,但我不知道为什么队列正在挑选相同的消息并发送到处理,而重复的消息只在5分钟后才开始挑选。 锁定时间为5分钟。 有人能帮帮我吗? 提前谢谢。 推荐答案 使用Azure Service Bus消息将在接收方未对消息执行操作时重新处理。一个行动将是完成、推 ..
发布时间:2022-08-16 11:42:53 其他开发

Azure Service Bus是否可能创建了该消息的副本?

我们在Azure Service Bus中遇到了一些奇怪的行为,除了Azure中的某个错误之外,我们不知道如何解释。事情是这样的: 我们已向Azure Service Bus发送过一次消息 执行发送消息的调用花了一分钟多一点的时间,但还是成功了,之后消息接收正常 大约半秒后出现重复消息,EnqueuedTimeUtc和SequenceNumber与第一条消息不同,但它具有与我们生成的相同 ..
发布时间:2022-08-16 11:25:33 其他开发

正在清理没有序列号的Azure Service Bus上的延迟消息

如果我丢失了序列号,是否有办法恢复或删除Azure Service Bus上的延迟消息? 场景是:我想使用BrokeredMessage.Defer()来延迟一条消息。我计划记录序列号,并在以后使用它来检索消息。但是,如果出现错误-假设部署了一些错误代码-并且没有正确记录序列号,则该消息似乎将以延迟状态驻留在服务总线上,直到消息过期,这可能是永远的。 这主要是因为该消息将占用队列或订阅上的 ..
发布时间:2022-08-16 11:20:23 其他开发

具有服务总线主题订阅和逻辑应用程序Web挂钩的Azure事件网格未触发

我正在使用Service Bus Premium创建事件订阅(事件网格),并使用WebHook(逻辑应用程序终结点)创建终结点。 我的用例是:只要在服务总线主题中接收到消息,事件就应该被触发,并且应该调用WebHook。 WebHook终结点为Logic App URI。 问题:对于主题中的15-20条消息,事件被触发并触发逻辑应用程序,在此之后,即使是任何数量的消息,事件也不会 ..

控制队列轮询时间

我有一段代码,每当在我的Web应用程序上添加新文章时,它都会将消息推送到服务总线队列。然后,My Functions应用程序中带有SendGrid输出的ServiceBusTrigger会给我发送一封电子邮件,通知我某人添加了一篇新文章。 这根本不经常发生,我决定让它这样做的唯一原因是为了让我的脚接触一些很棒的Azure服务。 我的问题是--因为我并不真的在乎实时回复这些通知电子邮件……如 ..
发布时间:2022-05-19 18:09:26 其他开发

有没有办法在Azure Service Bus上用Python发送带有主题和订阅的文件?

总结问题: 我正在尝试在Azure Service Bus上发送带有主题和订阅的CSV文件。我正在关注官方的快速入门here,并成功连接了ASB并打印了消息。我想做的下一步是在ASB上发送CSV文件,以便监听程序复制这些文件。CSV文件当前位于坞站内。是否可以发送CSV文件?如果是这样的话,是如何做到的?任何可以指引我正确方向的有用资源我都非常感激。 我尝试的内容: 主题和订阅已由另一个 ..
发布时间:2022-05-19 18:02:01 Python

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

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

如何通过SAS验证Azure REST API到Service Bus

我正在尝试使用本文档中提供的REST API向Service Bus队列发送消息: https://docs.microsoft.com/en-us/rest/api/servicebus/send-message-to-queue 请注意,我不能使用Azure库来执行此任务,因为据我所知,现在没有可用的服务,并且我正在设置Python中的测试触发器以模拟将从Service Now进行的RE ..
发布时间:2022-05-19 17:46:08 Python

有没有可能让一个大规模运输传奇对来自多个巴士(多巴士)的事件做出反应?

我有一个MassTransport Saga,可以很好地处理已为其配置了Saga的Bus(Azure Service Bus)上下文中的事件、活动等。 在其中一种状态下,我需要将消息发送到另一条不同的总线(另一条Azure服务总线)。这在使用MultiBus时工作得很好。但是,在下一步中,我希望从该单独的总线接收主题消息并对其做出反应。 在MassTransport Saga中支持自动 ..
发布时间:2022-05-19 17:42:01 其他开发

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

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

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

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