Azure Function：用Http Trigger替代Blob Trigger实现可靠操作并传递Blob名称

你的问题出在name参数无法被Http Trigger解析——Blob Trigger会自动从触发的Blob路径中提取{name}参数，但Http Trigger不会默认提供这个值，你需要把name作为路由参数或者查询参数传递给函数，这样绑定系统才能识别它。

推荐实现方式：使用路由参数传递Blob名称 #

这种方式最直观，和你原来的Blob Trigger逻辑最接近，把Blob名称作为URL的一部分传递：

[FunctionName("ProcessOpenOrders")]
public static async Task<HttpResponseMessage> Run(
    // 指定路由，把{name}作为路由参数
    [HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = "ProcessOpenOrders/{name}")] HttpRequestMessage request,
    // 用路由参数{name}绑定输入Blob
    [Blob("%InboundBlobPath%/{name}", FileAccess.Read)] Stream myBlob,
    // 自动注入路由参数name
    string name,
    TraceWriter traceWriter,
    // 用同一个name绑定输出Blob
    [Blob("%OutboundBlobPath%/{name}", FileAccess.Write)] Stream outputStream,
    ExecutionContext context)
{
    // 这里保留你原来的业务逻辑，读取myBlob处理后写入outputStream
    traceWriter.Info($"开始处理Blob: {name}");
    
    // 示例处理逻辑（替换成你的实际代码）
    await myBlob.CopyToAsync(outputStream);
    
    // 返回明确的响应状态码，确认处理完成
    return request.CreateResponse(HttpStatusCode.OK, $"Blob {name} 处理完成");
}

调用这个函数时，URL会是类似这样的：https://<你的函数应用名>.azurewebsites.net/api/ProcessOpenOrders/your-blob-name?code=<你的函数密钥>

替代方式：使用查询参数传递Blob名称 #

如果你不想修改路由，也可以通过查询参数传递name，但这种情况下不能直接用自动绑定，需要手动读取查询参数后获取Blob：

[FunctionName("ProcessOpenOrders")]
public static async Task<HttpResponseMessage> Run(
    [HttpTrigger(AuthorizationLevel.Function, "get", "post")] HttpRequestMessage request,
    TraceWriter traceWriter,
    ExecutionContext context,
    // 注入Blob存储的绑定器，手动获取Blob
    Binder binder)
{
    // 从查询参数中获取name
    var queryParams = request.RequestUri.ParseQueryString();
    var name = queryParams["name"];
    if (string.IsNullOrEmpty(name))
    {
        return request.CreateResponse(HttpStatusCode.BadRequest, "缺少name参数");
    }

    // 手动绑定输入Blob
    var inputBlobAttribute = new BlobAttribute(Environment.GetEnvironmentVariable("InboundBlobPath") + "/" + name, FileAccess.Read);
    using (var myBlob = await binder.BindAsync<Stream>(inputBlobAttribute))
    {
        // 手动绑定输出Blob
        var outputBlobAttribute = new BlobAttribute(Environment.GetEnvironmentVariable("OutboundBlobPath") + "/" + name, FileAccess.Write);
        using (var outputStream = await binder.BindAsync<Stream>(outputBlobAttribute))
        {
            // 你的处理逻辑
            await myBlob.CopyToAsync(outputStream);
        }
    }

    return request.CreateResponse(HttpStatusCode.OK, $"Blob {name} 处理完成");
}

调用URL示例：https://<你的函数应用名>.azurewebsites.net/api/ProcessOpenOrders?name=your-blob-name&code=<你的函数密钥>

如果你还是想保留Blob Trigger，解决它停止响应的问题，可以尝试以下步骤：

• 开启Always On（仅适用于专用/弹性计划）：在Azure门户的函数应用→配置→常规设置中，开启Always On，避免应用长时间闲置被回收，导致触发器停止工作。
• 使用事件网格驱动Blob Trigger：确保你的存储账户是General Purpose v2或Blob存储账户（支持事件网格），Blob Trigger会自动创建事件网格订阅，这样触发器响应更及时且可靠。如果订阅丢失，可以手动在存储账户的事件网格中重新创建订阅，指向函数应用的Blob Trigger端点。
• 检查存储账户权限：确保函数应用使用的身份（系统托管身份或存储账户密钥）拥有Storage Blob Data Contributor权限，避免触发器无法读取Blob事件或访问存储。
• 调整host.json配置：修改Blob Trigger的重试和超时设置，避免死信消息卡住触发器。示例host.json：

{
  "version": "2.0",
  "extensions": {
    "blobs": {
      "maxDequeueCount": 5, // 最大重试次数
      "visibilityTimeout": "00:05:00" // 重试间隔
    }
  }
}

• CI/CD发布后自动重启：在Azure DevOps（原VSTS）的发布管道中，添加一个「Azure Function App 管理」任务，选择「重启」操作，确保发布后函数应用和触发器完全初始化。
• 排查日志：通过Application Insights或Kudu日志查看触发器的错误信息，搜索BlobTrigger相关日志，定位是否有连接失败、订阅过期等具体问题。

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