使用放弃的服务总线消息重新触发Azure函数

Question

我有一个服务总线主题，它有40万条消息从一个Azure函数推送到它。我有第二个Azure函数接收消息作为触发器。第2个函数运行时，成功处理了98%的消息。它给我留下了大约8000条失败的消息。由于异常或我的代码，消息被放弃了。我现在有8,000条消息坐在一个主题的订阅者中，我不能让函数重新尝试处理。

订阅服务器最初被设置为只允许1邮件传递。我之所以这么做，是因为在调试时，我看到同一条消息被多次处理。我不确定这是在Visual Studio中进行本地调试的副作用，还是消息会多次发送到函数。我假设这就是导致那些消息在被放弃后函数没有重新运行的原因（如果支持的话？）。

我已经将订阅者传递计数更改为5，希望它能将消息重新传递给函数。它没有。我现在需要做什么来获得剩余的8000条消息来再次触发第2个功能？

最坏的情况是，我可以删除订阅，重新创建订阅并重新运行第一个函数，这应该只是发布与原始丢失的8,000条消息相关联的html" target="_blank">数据（我有逻辑来处理第一个函数中丢失的数据）。这将导致第二个函数重新启动。我想弄清楚当订阅有像这样的孤立消息时如何处理它，我将在升级到生产时体验到这一点。我希望这是自动化的，而不是必须处理手动清理和重新运行的过程第二次。

我用C#Functions1.0在完整的框架上编写了这些函数。

Answer 1

如果MaxDeliveryCount为reach，则消息将被发送到死信队列。
您可以将订阅视为子队列，以便仍然可以访问这些消息。

查看关于如何访问死信队列的文章：

• 如何访问Azure订阅上的死信子队列？

首先，您的场景将增加MaxDeliveryCount。

 [FunctionName("my-subscription-failure")]
 public static async Task RunFailure(
        [ServiceBusTrigger("%MytopicName%", "%MySubscription%/$DeadLetterQueue", Connection = "MyconnectionString")] BrokeredMessage message,
        [ServiceBus( "%MytopicName%", AccessRights.Send, Connection = "MyconnectionString")] ICollector<BrokeredMessage> queueBinding,
        TraceWriter log, ExecutionContext context)
{
    // fist check if the message can be resent (it could be a message that can't be replay)
    ...

    // If ok, resent the message
    queueBinding.Add(message);
}