Azure WebJobs和ServiceBusTrigger

Question

毒消息处理如何为Azure WebJobs SDK的ServiceBusTrigger工作？我正在寻找推送的服务总线队列消息已退出队列超过'x'时间到不同的ServiceBus（或）存储队列

这里和这里的在线留档以及这里的SDK示例没有关于ServiceBusTrigger如何处理有毒消息的示例。这是半成品吗？

我尝试使用dequeueCount参数实现自定义毒药消息处理，但ServiceBurstriggers似乎不支持它，因为我得到了运行时异常{“使用此触发器时无法绑定参数'dequeueCount”。}

public static void ProcessMessage([ServiceBusTrigger(topicName: "abc", subscriptionName: "abc.gdp")] NotificationMessage message,
            [Blob("rox/{PayloadId}", FileAccess.Read)] Stream blobInput, Int32 dequeueCount)
        {
            throw new ArgumentNullException();
        }




Answer 1

为了补充Brendan Green的回答，WebJobs SDK对处理失败的消息调用放弃，在最大重试次数后，这些消息通过服务总线移动到死信队列。定义何时将消息移动到死信队列中的属性（如最大传递计数、生存时间和PeekLock持续时间）可以在服务总线中更改-

您可以在这里找到有关SB死信队列的更多信息：https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-dead-letter-queues

Answer 2

看起来WebJobs目前在内部处理这个问题。

参考：如何将Azure Service Bus与WebJobs SDK一起使用

具体章节：

ServiceBustigger的工作原理

SDK在PeekLock模式下接收消息，如果函数成功完成，则调用消息完成；如果函数失败，则调用放弃。如果函数的运行时间超过PeekLock超时时间，则会自动续订锁。

服务总线执行自己的有毒队列处理，因此它既不受WebJobs SDK控制，也不可在WebJobs SDK中配置。

附加参考

无法在Azure Functions中控制或配置有毒消息处理。服务总线本身处理有毒消息。

Answer 3

虽然无法获取ServiceBus消息的dequeueCount属性，但始终可以绑定到BrokeredMessage而不是NotificationMessage并从中获取属性。