基于CleanArchitecture的Azure Function依赖注入配置求助

问题根源 #

报错是因为ApplicationDbContext依赖ICurrentUserService，但Time Trigger类型的Azure Function属于无用户上下文的后台任务，默认DI容器找不到该服务的有效实现，导致激活失败。

具体解决步骤 #

1. 初始化Azure Function的DI框架 #

在Function项目的Program.cs中搭建基础DI容器结构，isolated模式示例如下：

var host = new HostBuilder()
    .ConfigureFunctionsWorkerDefaults()
    .ConfigureServices(services =>
    {
        // 后续服务注册逻辑写在这里
    })
    .Build();

host.Run();

2. 注册Infrastructure服务并替换ICurrentUserService实现 #

因为后台任务无实际用户，需要提供一个适配后台场景的空实现来满足ApplicationDbContext的依赖：

.ConfigureServices(services =>
{
    // 加载配置文件
    var configuration = new ConfigurationBuilder()
        .SetBasePath(Directory.GetCurrentDirectory())
        .AddJsonFile("local.settings.json", optional: true, reloadOnChange: true)
        .AddEnvironmentVariables()
        .Build();

    // 注册Infrastructure层的所有服务
    services.AddInfrastructureServices(configuration);

    // 替换原有ICurrentUserService注册，使用后台专用实现
    services.AddScoped<ICurrentUserService, BackgroundCurrentUserService>();
})

创建对应的空实现类：

public class BackgroundCurrentUserService : ICurrentUserService
{
    // 可设置固定标识，用于审计日志或数据追踪
    public string? UserId => "background-task-worker";
    public string? UserName => "Background Sync Task";
}

3. 验证ApplicationDbContext的构造函数 #

确认Infrastructure层的ApplicationDbContext构造函数正确注入ICurrentUserService：

public class ApplicationDbContext : DbContext
{
    private readonly ICurrentUserService _currentUserService;

    public ApplicationDbContext(DbContextOptions<ApplicationDbContext> options, ICurrentUserService currentUserService)
        : base(options)
    {
        _currentUserService = currentUserService;
    }

    // DbSet定义及其他业务逻辑...
}

4. 在Time Trigger Function中注入服务 #

直接在Function类的构造函数中注入所需服务，示例如下：

public class DataSyncFunction
{
    private readonly ApplicationDbContext _dbContext;
    private readonly IThirdPartyApiService _thirdPartyApiService;

    public DataSyncFunction(ApplicationDbContext dbContext, IThirdPartyApiService thirdPartyApiService)
    {
        _dbContext = dbContext;
        _thirdPartyApiService = thirdPartyApiService;
    }

    [Function("DataSyncFunction")]
    public async Task Run([TimerTrigger("0 */5 * * * *")] TimerInfo timer)
    {
        // 1. 从SQL Server拉取待同步数据
        var pendingData = await _dbContext.TargetEntities.Where(e => !e.IsSynced).ToListAsync();

        // 2. 调用第三方API
        var syncResult = await _thirdPartyApiService.SyncDataAsync(pendingData);

        // 3. 更新数据库同步状态
        foreach (var item in pendingData)
        {
            item.IsSynced = true;
            item.SyncedAt = DateTime.UtcNow;
        }
        await _dbContext.SaveChangesAsync();
    }
}

5. 关键注意事项 #

• 确保local.settings.json中配置了和WEBUI项目一致的数据库连接字符串：

  {
      "IsEncrypted": false,
      "Values": {
          "AzureWebJobsStorage": "UseDevelopmentStorage=true",
          "FUNCTIONS_WORKER_RUNTIME": "dotnet-isolated",
          "DefaultConnection": "Server=.;Database=YourDatabaseName;Trusted_Connection=True;TrustServerCertificate=True;"
      }
  }
  

• 若使用in-process模式的Azure Function，需改用Startup类配置DI，但推荐优先使用isolated模式（上述示例基于该模式）。
• 若AddInfrastructureServices方法已注册过ICurrentUserService，后续的AddScoped会覆盖原有注册，确保后台任务使用我们的适配实现。

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