如何为.NET 6独立Azure Function实现多租户动态配置加载？

可以在请求生命周期内根据client-id标签加载对应配置，但必须结合缓存机制避免触发Azure App Configuration标准层的请求次数限制（每小时3000次）。下面是具体实现方案：

核心思路 #

• 利用缓存（内存缓存或分布式缓存）存储已加载的租户配置，避免每次请求都调用App Configuration
• 在请求中间件中提取client-id，优先从缓存获取对应配置；缓存未命中时，再从App Configuration拉取并写入缓存
• 配置缓存过期策略，平衡配置新鲜度与请求次数

实现步骤与代码示例 #

1. 配置Program.cs，注册必要服务 #

var host = new HostBuilder()
    .ConfigureAppConfiguration((context, builder) =>
    {
        var cs = Environment.GetEnvironmentVariable("AppConfigConnectionString");
        // 先加载基础配置（非租户特定）
        builder.AddAzureAppConfiguration(options =>
        {
            options.Connect(cs)
                   .Select(KeyFilter.Any, LabelFilter.Null); // 加载无标签的基础配置
        });
    })
    .ConfigureServices(services =>
    {
        // 注册内存缓存
        services.AddMemoryCache();
        // 注册App Configuration客户端，用于动态加载租户配置
        services.AddAzureAppConfiguration();
        // 注册自定义配置读取服务
        services.AddScoped<ITenantConfigService, TenantConfigService>();
        // 注册请求中间件
        services.AddScoped<RequestMiddleware>();
    })
    .ConfigureFunctionsWorkerDefaults(builder =>
    {
        // 添加自定义中间件到管道
        builder.UseMiddleware<RequestMiddleware>();
    })
    .Build();

host.Run();

2. 实现租户配置读取服务 #

public interface ITenantConfigService
{
    Task<IConfiguration> GetTenantConfigAsync(string clientId);
}

public class TenantConfigService : ITenantConfigService
{
    private readonly IMemoryCache _cache;
    private readonly IConfiguration _rootConfig;
    private readonly string _appConfigConnString;

    public TenantConfigService(IMemoryCache cache, IConfiguration rootConfig)
    {
        _cache = cache;
        _rootConfig = rootConfig;
        _appConfigConnString = _rootConfig["AppConfigConnectionString"];
    }

    public async Task<IConfiguration> GetTenantConfigAsync(string clientId)
    {
        var cacheKey = $"TenantConfig_{clientId}";
        // 尝试从缓存获取
        if (_cache.TryGetValue(cacheKey, out IConfiguration tenantConfig))
        {
            return tenantConfig;
        }

        // 缓存未命中，从App Configuration加载
        var configBuilder = new ConfigurationBuilder();
        configBuilder.AddAzureAppConfiguration(options =>
        {
            options.Connect(_appConfigConnString)
                   .Select(KeyFilter.Any, clientId); // 按clientId标签筛选配置
        });

        tenantConfig = configBuilder.Build();

        // 将配置存入缓存，设置5分钟过期（可根据需求调整）
        var cacheOptions = new MemoryCacheEntryOptions()
            .SetAbsoluteExpiration(TimeSpan.FromMinutes(5));
        _cache.Set(cacheKey, tenantConfig, cacheOptions);

        return tenantConfig;
    }
}

3. 修改请求中间件，加载租户配置并注入上下文 #

public class RequestMiddleware
{
    private readonly ITenantConfigService _tenantConfigService;

    // 通过构造函数注入服务
    public RequestMiddleware(ITenantConfigService tenantConfigService)
    {
        _tenantConfigService = tenantConfigService;
    }

    public async Task Invoke(FunctionContext context, FunctionExecutionDelegate next)
    {
        var requestData = await context.GetHttpRequestDataAsync();
        if (requestData?.Headers.TryGetValues("client-id", out var clientIds) == true && clientIds.Any())
        {
            var clientId = clientIds.First();
            // 获取租户配置
            var tenantConfig = await _tenantConfigService.GetTenantConfigAsync(clientId);
            // 将租户配置存入Function上下文，供后续函数使用
            context.Items["TenantConfig"] = tenantConfig;
        }

        await next(context);
    }
}

4. 在Function中使用租户配置 #

public class MyFunction
{
    [Function("MyFunction")]
    public async Task<HttpResponseData> Run(
        [HttpTrigger(AuthorizationLevel.Function, "get", "post")] HttpRequestData req,
        FunctionContext executionContext)
    {
        var response = req.CreateResponse(HttpStatusCode.OK);
        
        if (executionContext.Items.TryGetValue("TenantConfig", out var configObj) && configObj is IConfiguration tenantConfig)
        {
            var tenantSetting = tenantConfig["TenantSpecificSetting"];
            await response.WriteStringAsync($"Tenant setting: {tenantSetting}");
        }
        else
        {
            await response.WriteStringAsync("No tenant config found");
        }

        return response;
    }
}

关键注意事项 #

• 缓存策略：根据业务需求调整缓存过期时间，比如配置变更不频繁可设置更长过期时间，进一步减少App Configuration请求
• 错误处理：需添加异常捕获逻辑，处理App Connection连接失败、clientId无效等情况
• 分布式缓存：如果Function运行在多实例环境，建议使用Redis等分布式缓存，确保各实例缓存一致
• 请求限制：按上述缓存策略（5分钟过期），每个租户每小时仅需12次请求，远低于标准层3000次/小时的限制

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