在.NET7定时触发隔离进程函数应用中配置Header Propagation遇阻

核心问题原因 #

隔离进程Azure Functions基于Worker运行时，中间件模型和ASP.NET Core HTTP管道完全不同，原生HeaderPropagationMiddleware是为ASP.NET Core设计的，无法直接通过builder.UseMiddleware<HeaderPropagationMiddleware>注册（会触发CS0311类型转换错误）；同时定时触发场景没有HTTP请求上下文，无法自动从请求头获取要传播的字段，需要手动初始化HeaderPropagationValues.Headers集合。

完整配置步骤 #

1. 注册Header Propagation服务 #

在Program.cs中完成基础服务配置，指定需要传播的头字段：

var builder = new HostBuilder();
builder.ConfigureFunctionsWorkerDefaults();

// 注册Header Propagation服务，配置要传播的头
builder.Services.AddHeaderPropagation(options =>
{
    // 替换为你实际需要传播的头，比如Authorization
    options.Headers.Add("Authorization");
});

// 保留你已完成的AccessToken管理服务注册
builder.Services.AddScoped<IAccessTokenService, AccessTokenService>();

2. 实现适配Worker的自定义中间件 #

创建自定义中间件，实现IFunctionsWorkerMiddleware接口，负责初始化HeaderPropagationValues并设置要传播的头：

using Microsoft.Azure.Functions.Worker;
using Microsoft.Azure.Functions.Worker.Middleware;
using Microsoft.AspNetCore.HeaderPropagation;

public class HeaderPropagationFunctionsMiddleware : IFunctionsWorkerMiddleware
{
    private readonly HeaderPropagationValues _headerPropagationValues;
    private readonly IHeaderPropagationFeature _headerPropagationFeature;

    public HeaderPropagationFunctionsMiddleware(HeaderPropagationValues headerPropagationValues, IHeaderPropagationFeature headerPropagationFeature)
    {
        _headerPropagationValues = headerPropagationValues;
        _headerPropagationFeature = headerPropagationFeature;
    }

    public async Task Invoke(FunctionContext context, FunctionExecutionDelegate next)
    {
        // 初始化Headers集合，解决未初始化的运行时错误
        _headerPropagationValues.Headers ??= new Dictionary<string, string[]>(StringComparer.OrdinalIgnoreCase);

        // 从AccessToken服务获取令牌，设置到传播头中（定时触发场景需手动注入头值）
        var tokenService = context.InstanceServices.GetRequiredService<IAccessTokenService>();
        var accessToken = await tokenService.GetTokenAsync();
        
        // 将头值同步到Feature和Values中，供后续HttpClient使用
        _headerPropagationFeature.Headers["Authorization"] = $"Bearer {accessToken}";
        _headerPropagationValues.Headers["Authorization"] = new[] { $"Bearer {accessToken}" };

        await next(context);
    }
}

3. 注册自定义中间件 #

在Program.cs的ConfigureFunctionsWorkerDefaults中注册上述中间件：

builder.ConfigureFunctionsWorkerDefaults(workerBuilder =>
{
    // 注册自定义Header传播中间件
    workerBuilder.UseMiddleware<HeaderPropagationFunctionsMiddleware>();
});

4. 配置HttpClient使用Header Propagation #

确保你的HttpClient配置中添加AddHeaderPropagation()，让它自动使用传播的头：

builder.Services.AddHttpClient("MyTargetApiClient")
    .AddHeaderPropagation();

关键注意事项 #

• 定时触发场景没有HTTP请求上下文，必须手动从AccessToken服务或配置中获取要传播的头值，无法像ASP.NET Core那样自动从Request头读取。
• 自定义中间件中必须初始化HeaderPropagationValues.Headers集合，否则会触发未初始化的运行时异常。

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