azureservicebus相关内容
official document中,每个命名空间最多允许100个分区队列。但是一个队列中允许的分区数有上限吗? 谢谢 推荐答案 谢谢Sajeetharan, 基于MS DOC 目前,Service Bus允许多达100个分区队列或主题 每个命名空间。每个分区的队列或主题都计入 每个命名空间10,000个实体的配额(不适用于Premium 层)。 没有单据。如here
..
我正在尝试使用具有间隔设置的UseReter,使用MassTransport和Azure Service Bus作为传输。 消费者代码: public async Task Consume(ConsumeContext context) { _log.InfoFormat("Strated working on {0}", co
..
我有两个Azure功能,一个是http功能,另一个是队列触发功能。在http函数中,我向队列添加消息,并在队列中触发处理它。当我在队列中记录消息时,触发有时会多次触发相同的消息?原因是什么? 提前谢谢 推荐答案 可能有几个原因。不看代码,我的猜测如下: 基于HTTP的函数被多次调用。可以通过分配从邮件属性派生的唯一邮件ID,然后使用ASB的本机重复数据消除来进行验证。 基
..
我希望特定传奇故事的所有消息都发生在同一主题上。 我是这样设置我的传奇故事的: public void ConfigureServices(IServiceCollection services) { services.AddMassTransit(x => { var machine = new MyStateMachine(); va
..
using Azure.Messaging.ServiceBus; 我当前有一个ServiceBusClient,其中我将connectionString作为参数传递给其构造函数: var client = new ServiceBusClient(connectionString); 现在假设我有另一个名为Handler的类,它希望ServiceBusClient作为其构造函数的参
..
我需要一个关于如何对服务总线队列进行CRUD操作的示例。 我实际上需要Microsoft.Azure.Management.ServiceBus.SBQueue类的实例,以便可以计算该队列中的消息数。 推荐答案 较老的方法是使用ManagementClient var managementClient = new ManagementClient(connectionStr
..
我在蔚蓝服务巴士上工作。实际上,我的服务总线队列正在处理一条消息3次。我的消息锁定时间是5分钟。每条消息最多处理2分钟,但我不知道为什么队列正在挑选相同的消息并发送到处理,而重复的消息只在5分钟后才开始挑选。 锁定时间为5分钟。 有人能帮帮我吗? 提前谢谢。 推荐答案 使用Azure Service Bus消息将在接收方未对消息执行操作时重新处理。一个行动将是完成、推
..
我正在编写一个Azure函数来获取Azure服务总线中的消息。 我希望手动处理任何异常("autoCompleteMessages": false) 无法确定如何将完成或放弃发送回服务队列。 已尝试选项1: [FunctionName("SBQ_F1_VC")] public static async Task Run([ServiceBusTrigger("sbqfn1", Conn
..
我们在Azure Service Bus中遇到了一些奇怪的行为,除了Azure中的某个错误之外,我们不知道如何解释。事情是这样的: 我们已向Azure Service Bus发送过一次消息 执行发送消息的调用花了一分钟多一点的时间,但还是成功了,之后消息接收正常 大约半秒后出现重复消息,EnqueuedTimeUtc和SequenceNumber与第一条消息不同,但它具有与我们生成的相同
..
如果我丢失了序列号,是否有办法恢复或删除Azure Service Bus上的延迟消息? 场景是:我想使用BrokeredMessage.Defer()来延迟一条消息。我计划记录序列号,并在以后使用它来检索消息。但是,如果出现错误-假设部署了一些错误代码-并且没有正确记录序列号,则该消息似乎将以延迟状态驻留在服务总线上,直到消息过期,这可能是永远的。 这主要是因为该消息将占用队列或订阅上的
..
我正在使用Service Bus Premium创建事件订阅(事件网格),并使用WebHook(逻辑应用程序终结点)创建终结点。 我的用例是:只要在服务总线主题中接收到消息,事件就应该被触发,并且应该调用WebHook。 WebHook终结点为Logic App URI。 问题:对于主题中的15-20条消息,事件被触发并触发逻辑应用程序,在此之后,即使是任何数量的消息,事件也不会
..
我有一段代码,每当在我的Web应用程序上添加新文章时,它都会将消息推送到服务总线队列。然后,My Functions应用程序中带有SendGrid输出的ServiceBusTrigger会给我发送一封电子邮件,通知我某人添加了一篇新文章。 这根本不经常发生,我决定让它这样做的唯一原因是为了让我的脚接触一些很棒的Azure服务。 我的问题是--因为我并不真的在乎实时回复这些通知电子邮件……如
..
总结问题: 我正在尝试在Azure Service Bus上发送带有主题和订阅的CSV文件。我正在关注官方的快速入门here,并成功连接了ASB并打印了消息。我想做的下一步是在ASB上发送CSV文件,以便监听程序复制这些文件。CSV文件当前位于坞站内。是否可以发送CSV文件?如果是这样的话,是如何做到的?任何可以指引我正确方向的有用资源我都非常感激。 我尝试的内容: 主题和订阅已由另一个
..
我们有一个包含200K+消息的服务总线(标准计划)队列。我们希望以2K-5K的大小从服务总线读取消息,并使用Azure函数(每30分钟)将其批量插入到SQL DB中。 大多数情况下,ReceiveMessagesAsync会返回几百条消息,有时会达到一位数。我确实理解MaxMessages参数不能保证消息计数,但我仍然想知道是否有任何方法可以优化它,使其返回至少50%的最大消息计数。 现在
..
我正在尝试使用本文档中提供的REST API向Service Bus队列发送消息: https://docs.microsoft.com/en-us/rest/api/servicebus/send-message-to-queue 请注意,我不能使用Azure库来执行此任务,因为据我所知,现在没有可用的服务,并且我正在设置Python中的测试触发器以模拟将从Service Now进行的RE
..
我有一个MassTransport Saga,可以很好地处理已为其配置了Saga的Bus(Azure Service Bus)上下文中的事件、活动等。 在其中一种状态下,我需要将消息发送到另一条不同的总线(另一条Azure服务总线)。这在使用MultiBus时工作得很好。但是,在下一步中,我希望从该单独的总线接收主题消息并对其做出反应。 在MassTransport Saga中支持自动
..
我正在使用具有Azure Service Bus的MasstranSite,我希望实现的是从API调用Bus,其中的一些请求将触发较长的进程,但也会立即获得已收到请求的响应。 实现这一目标的最佳方式是什么? 我应该将JobConsumer和GetResponse与JobSubmissionAccept一起使用,还是有更好的选择? 推荐答案 如果您的使用者需要很长时间,通常超过五分
..
我正在尝试使用服务总线队列触发器从队列中消费消息,并执行一些需要一些时间才能完成的工作。我不希望在处理消息时其他处理器拾取该消息。我在Host.json中有以下配置。当我从等待接收者的队列收到消息时。CompleteAsync(LockToken); 我收到一个异常&提供的锁无效。锁定已过期,或者该邮件已从队列中删除。"; "serviceBus": { "prefetchCo
..
我有一个相当简单的函数,可以将消息发送到Azure ServiceBus队列。 public async Task SendMessagesToQueue(string serviceBusConnectionString, int message, string queueName) { try { Queue
..
我正在使用Azure.Messaging.ServiceBus库。 我创建ServiceBusClient和ServiceBusProcessor以开始接收队列消息,如下所示: var serviceBusClient = new ServiceBusClient(connectionString); ServiceBusProcessor processor = serviceBus
..