Java环境下Blob触发Azure Function特定错误重试机制实现

一、内置重试策略配置（host.json） #

通过修改host.json文件可配置全局或特定触发器的重试规则，实现自动重试同一Blob，无需手动重新上传文件。

1. 全局重试配置（适用于所有触发器） #

全局配置会对所有函数触发器生效，可指定重试策略、次数、间隔及触发重试的异常类型：

{
  "version": "2.0",
  "logging": {
    "applicationInsights": {
      "samplingSettings": {
        "isEnabled": true,
        "excludedTypes": "Request"
      }
    }
  },
  "retry": {
    "strategy": "exponentialBackoff",
    "maxRetryCount": 5,
    "delayInterval": "00:00:05",
    "maximumDelayInterval": "00:00:30",
    "retryOn": ["StorageException", "TimeoutException"]
  }
}

• strategy：可选fixedDelay（固定间隔重试）或exponentialBackoff（间隔指数递增）
• maxRetryCount：最大重试次数（不含首次执行）
• delayInterval：初始延迟时长（固定模式下为每次重试间隔）
• maximumDelayInterval：指数模式下的延迟上限
• retryOn：指定触发重试的异常类型（支持全类名或简短名称）

2. Blob触发器专属配置 #

若仅需给Blob触发器单独设置重试规则，可在extensions节点下配置：

{
  "version": "2.0",
  "extensions": {
    "blobs": {
      "retry": {
        "strategy": "fixedDelay",
        "maxRetryCount": 3,
        "delayInterval": "00:00:10",
        "retryOn": ["MyCustomTransientException"]
      }
    }
  }
}

二、特定错误场景的重试实现 #

针对业务逻辑中的特定临时错误（如第三方服务不可用、自定义业务异常），只需在代码中抛出对应异常，让内置重试策略捕获即可触发重试：

C#示例 #

public static async Task Run(
    [BlobTrigger("sample-container/{name}", Connection = "AzureWebJobsStorage")] Stream myBlob,
    string name,
    ILogger log)
{
    try
    {
        // 执行业务逻辑
        await ProcessBlobContentAsync(myBlob);
    }
    catch (ThirdPartyServiceUnavailableException ex)
    {
        log.LogError(ex, $"Blob {name}处理遇临时错误，触发重试");
        // 抛出异常触发内置重试
        throw;
    }
    catch (Exception ex)
    {
        log.LogError(ex, $"Blob {name}处理遇不可恢复错误");
        // 手动将失败Blob移至死信容器，避免重复触发
        await MoveBlobToDeadLetterContainerAsync(name);
    }
}

Python示例 #

import azure.functions as func
import logging

def main(myblob: func.InputStream):
    logging.info(f"处理Blob: {myblob.name}，大小: {myblob.length}字节")
    try:
        # 执行业务逻辑
        process_blob_content(myblob)
    except ThirdPartyServiceUnavailableError as e:
        logging.error(f"Blob {myblob.name}处理遇临时错误，触发重试: {str(e)}")
        # 抛出异常触发内置重试
        raise
    except Exception as e:
        logging.error(f"Blob {myblob.name}处理遇不可恢复错误: {str(e)}")
        # 手动移至死信容器
        move_to_dead_letter_container(myblob.name)

三、常见触发器的内置重试行为 #

不同触发器的默认重试逻辑存在差异，核心触发器的默认行为如下：

• Blob触发器：默认无自动重试，必须通过host.json配置重试策略才会触发，重试期间会锁定Blob防止重复处理。
• Queue触发器：默认内置指数回退重试，最多重试5次（可通过host.json修改），超过次数后消息自动移入死信队列。
• HTTP触发器：默认无自动重试，需手动在代码中实现（如使用Polly库），或通过上游服务（如API管理）配置重试。
• Event Hub触发器：默认基于Event Hub内置机制重试，可通过host.json配置最大重试次数和间隔，失败事件会重新进入分区待处理。
• Timer触发器：默认无自动重试，若执行失败需手动在代码中捕获异常实现重试，或配置全局重试策略。

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