Microsoft Azure Service Bus提供托管,安全且广泛可用的基础架构,用于广泛的通信,大规模事件分发,命名和服务发布。端点可以位于网络地址转换(NAT)边界之后,也可以绑定到频繁更改,动态分配的IP地址或两者。 Service Bus提供99.9%的正常运行时间SLA。
AsyncCollector 是一种非常好的简化消息发送的方式 然而,这涉及到在天蓝色函数中拥有逻辑,而我更喜欢在服务中拥有逻辑 我怎样才能注射
将达到最大传递计数的消息移至错误/新队列而不是死信 - 公共交通 Azure 服务总线
我们需要一种方法来处理死信队列中的消息,但Azure服务总线资源管理器似乎不支持application/vnd.masstransit+json内容类型来重新发送所选消息。 很少
Azure 服务总线 - 并行处理多个消息 (MaxConcurrentCallsPerSession)
我正在尝试并行处理来自启用了会话的队列的多条消息。例如,我尝试将 MaxConcurrentCallsPerSession 设置为 5,但我仍然一次收到 1 条消息...
Kafka 提供了一个功能,我们可以指定生产者批量大小。这是一次可以发送到队列的消息的大小。好处是我们可以减少网络数量
我正在开发一个系统,该系统将涉及分解为小任务的大量数据同步。我将每个小任务作为作业/消息添加到 Azure 服务总线队列上。 我有 X 个
错误索引方法“IntegrationFunction”无法从类型“Microsoft.Azure.EventHubs.EventData”转换
我很难理解为什么我的 Azure 函数收到以下错误。 错误: 错误索引方法“IntegrationFunction”无法从类型“Microsoft.Azure.EventHubs.Even...”转换...
我有一个 Azure 函数,当前使用来自 Azure 服务总线的消息,进行一些转换并将消息发布到 Azure 事件中心。不过,我还想给
使用 Node.js 创建服务总线主题消息时添加自定义消息属性
我有一个具有多个订阅的主题,需要为每个订阅添加一个过滤器以触发相应的功能应用程序。 这是我用于创建消息的 Node.js 代码: 常量路由器 =
Azure - 是什么导致 ServiceBus 主题被“分区”
所以我有一个二头肌文件,它迭代 200 多个字符串的数组,并且应该为每个字符串创建一个相关过滤器。 var strings = [ "xxx", "yyyy" ... ] 解决...
我有一个优惠券服务,可以监听传入的销售情况,并根据已购买/退回的商品等更新优惠券。 因此,我们使用 SaleCompletedEvent,这可能会将优惠券放入“rede...
使用应用服务计划时限制 Azure Function Service 总线触发并发消息处理的推荐方法
当 Azure 功能设置为应用服务计划时,限制 Azure 服务总线触发器并发消息处理的建议方法是什么? 我知道可以使用“最大并发
我已从 Azure 服务总线批量接收消息: IReadOnlyList receiveMessages = 等待 serviceBusReceiver.ReceiveMessagesAsync(maxMessages: maxMessages,
我正在使用 Microsoft Azure 服务总线队列来处理计算,我的程序运行良好几个小时,但从那时起我开始处理的每条消息都会出现此异常。 ...
所以我试图了解服务总线时序......尤其是锁的工作原理。人们可以选择手动调用 CompleteAsync,这就是我们正在做的事情。也可能是该过程...
我正在将 Azure 服务总线与 .NET Core 3.1 应用程序结合使用。我的应用程序收到数千个请求并将它们放入主题中。我想问的问题是我是否应该创建...
考虑这种情况: 有一个队列接收一些消息: 收到新消息 它开始处理它们(消息数量 未知,但我需要知道队列是否为空),
我有一个生成报告的 Azure 网站。生成报告大约需要 45 秒,我想迁移该辅助角色以减轻网站上的负载。 我一直在研究...
Azure 函数与服务总线触发器如何决定启用批处理时要传递到 azure 函数的消息数量
想知道当消息持续传递到服务总线主题时,azure 函数触发器将如何工作。据我所知,天蓝色功能会在主题发生时触发
我已经使用 terraform 创建了一个 Azure 服务总线队列,它已部署并正常工作。 我想为队列添加重试延迟。 我在 Python V2 模型中添加了以下行,但在
我们有一个天蓝色的功能,具有启用会话的服务总线触发器。我们正在尝试处理属于一个 sessionId 的一组消息。我们观察到该函数仅接收...