Azure Functions+EF Core DbContext：DI作用域与事务超时问题排查

问题结论 #

已解决：该错误源于未提交的事务锁定了数据表，其他函数调用等待解锁直至超时。

问题场景 #

开发基于.NET Core的Azure Function应用时，为请求添加事务处理后出现异常：当某个长耗时函数在事务开启（context.Database.BeginTransaction(...)）到提交（transaction.CommitAsync(...)）的过程中执行操作时，另一个函数调用无法向数据库保存数据，触发超时错误。

错误日志 #

[2024-01-04T07:23:29.957Z] An exception occurred in the database while saving changes for context type 'MyContext'.
[2024-01-04T07:23:29.957Z] System.InvalidOperationException: An exception has been raised that is likely due to a transient failure.
[2024-01-04T07:23:29.957Z]  ---> Microsoft.EntityFrameworkCore.DbUpdateException: An error occurred while saving the entity changes. See the inner exception for details.
[2024-01-04T07:23:29.958Z]  ---> Npgsql.NpgsqlException (0x80004005): Exception while reading from stream
[2024-01-04T07:23:29.958Z]  ---> System.TimeoutException: Timeout during reading attempt

未调用长耗时函数时，其他函数可正常保存数据，因此推测未关闭的事务阻塞了其他函数的DbContext操作。

环境配置 #

DbContext注册方式 #

builder.Services.AddDbContext<MyContext>(
    options => options
        .UseNpgsql(dbConnStr)
        .UseSnakeCaseNamingConvention());

按预期，每个Azure Functions调用应拥有独立的DI作用域，此配置在ASP.NET Core中可正常工作。

函数代码示例 #

两个函数均通过构造函数注入_dbContext：

public class LongerRunningFunctionClass {
    [Function("LongerRunningFunction")]
    public async HttpResponseData LongerRunningFunction([HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")] HttpRequestData req, FunctionContext executionContext) {
        await using var transaction = await _dbContext.Database.BeginTransactionAsync();
    
        try {
            // 包含数据库插入及外部服务调用的耗时操作
            await transaction.CommitAsync();
        }
        catch (Exception) {
            await transaction.RollbackAsync();
            throw;
        }
    } 
}


public class OtherFunctionClass {
    [Function("OtherFunction")]
    public async HttpResponseData OtherFunction([HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")] HttpRequestData req, FunctionContext executionContext) {
        await using var transaction = await _dbContext.Database.BeginTransactionAsync();
    
        try {
            // 快速插入操作
            await transaction.CommitAsync();
        }
        catch (Exception) { // 长耗时函数执行时，会触发此捕获块并抛出超时错误
            await transaction.RollbackAsync();
            throw;
        }
    }
}

解决方案 #

1. 缩短事务持有时间 #

将事务范围严格限制在仅数据库操作阶段，把外部服务调用等非数据库耗时操作移至事务提交/回滚之后，避免长时间持有数据库锁：

public async HttpResponseData LongerRunningFunction([HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")] HttpRequestData req, FunctionContext executionContext) {
    // 仅在数据库操作阶段开启事务
    await using var transaction = await _dbContext.Database.BeginTransactionAsync();
    try {
        // 执行数据库插入/更新操作
        await _dbContext.SaveChangesAsync();
        await transaction.CommitAsync();
    }
    catch (Exception) {
        await transaction.RollbackAsync();
        throw;
    }

    // 事务提交后再执行外部服务调用
    // Call external services here
}

2. 调整事务隔离级别 #

若业务允许，降低事务隔离级别（如从默认ReadCommitted改为ReadUncommitted），减少锁等待时间。注意此操作可能引入脏读风险，需结合业务场景评估：

// 开启事务时指定隔离级别
await using var transaction = await _dbContext.Database.BeginTransactionAsync(IsolationLevel.ReadUncommitted);

3. 优化数据库锁策略 #

• 检查并优化表的索引设计，避免更新操作锁定整张表或过多行；
• 对于PostgreSQL，可采用乐观锁（通过版本号字段）替代悲观锁，降低锁竞争概率。

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