Azure队列：Azure Function中如何设置重试间隔

方法一：通过host.json全局配置重试策略 #

这是最直接的全局管控方式，适用于所有队列触发的函数，支持固定延迟或指数退避两种重试策略：

固定延迟示例 #

设置每次重试间隔固定为10秒，消息被丢弃前总尝试次数（含首次处理）为10次：

{
  "version": "2.0",
  "extensions": {
    "queues": {
      "maxDequeueCount": 10,
      "retry": {
        "strategy": "fixedDelay",
        "maxRetryCount": 9,
        "delay": "00:00:10"
      }
    }
  }
}

指数退避示例 #

设置重试延迟从5秒起步，每次翻倍增长，最大延迟不超过1分钟，总尝试次数10次：

{
  "version": "2.0",
  "extensions": {
    "queues": {
      "maxDequeueCount": 10,
      "retry": {
        "strategy": "exponentialBackoff",
        "maxRetryCount": 9,
        "minimumInterval": "00:00:05",
        "maximumInterval": "00:01:00"
      }
    }
  }
}

注意：maxDequeueCount是消息被丢弃前的总尝试次数（含第一次处理），maxRetryCount是额外重试的次数，因此两者数值差1。

方法二：代码中手动控制延迟（灵活定制） #

如果需要根据错误类型、当前重试次数动态调整延迟规则，可以在函数代码中手动更新消息的可见性超时时间：

C#示例 #

public static async Task Run(
    [QueueTrigger("your-queue-name", Connection = "AzureWebJobsStorage")] CloudQueueMessage message,
    CloudQueue queue,
    ILogger log)
{
    try
    {
        // 执行你的业务逻辑
    }
    catch (Exception ex)
    {
        log.LogError(ex, $"处理消息失败，当前重试次数：{message.DequeueCount}");
        
        // 根据重试次数计算延迟，比如第n次重试用n*5秒
        int currentRetry = message.DequeueCount;
        TimeSpan retryDelay = TimeSpan.FromSeconds(currentRetry * 5);
        
        // 更新消息可见性，延迟后重新进入队列等待处理
        await queue.UpdateMessageAsync(message, retryDelay, MessageUpdateFields.Visibility);
    }
}

注意：需确保host.json中的maxDequeueCount设置为10，当重试次数耗尽后，消息会自动转入对应的死信队列{your-queue-name}-poison。

两种方式对比 #

• 全局配置：操作简单，统一管控所有队列函数的重试规则，适合通用场景。
• 手动控制：灵活性高，可针对单条消息或特定错误场景调整延迟策略，适合复杂业务需求。

内容的提问来源于stack exchange，提问作者Jorge