azure - 处理 Azure 队列时，当 dequeueCount 超过时，是否有办法防止消息进入有害队列？

Question

我有在 QueueTrigger 上运行的 Azure 函数，但如果 DequeueCount(最大重试次数)超过设置的限制(但继续向有害队列发送其他失败的消息)，我希望在不将消息发送到有害队列的情况下完成该函数

我当前的函数如下所示:

public async Task ProcessThis([QueueTrigger("message-queue")] Message message, string id, string popReceipt, int dequeueCount, ILogger logger)
{
   try
   {
     ...
     //process queue here
     ...
   }
   catch (Exception e)
   {
     if (dequeueCount == this._config.DequeueCount) //Currently it's set to 10
     {
       return; //If I return here, would the message still go into poison queue?
     }

     throw e;
   } 
}

我想知道这是否是防止消息因超过最大重试次数而失败而进入有害队列的正确方法。

Answer 1

如果函数未引发异常，Azure Function Runtime 会将其视为已成功处理的消息并将其从 Q 中删除。

如果抛出任何类型的异常，则运行时会将其视为失败并增加出队计数。如果新计数超出 maxDequeueCount，则会将其移至有毒 Q。See doc .

因此，如果您只是不想让任何内容进入毒 Q，只需向您的 ProcessThis() 添加一个 catch-all block 并抑制异常即可。