添加try块后Azure Functions中EF Core响应过慢的优化方案

问题场景 #

Azure Functions HTTP触发器代码通过try块调用多个异步EF Core查询（分别返回不同自定义DTO）构建JSON响应。本地环境下，移除try块时正常响应仅需3秒；但添加try块后，若SQL Server名称配置错误，错误响应耗时长达约30秒。尝试过合并SQL调用，但多DTO处理存在困难。

核心原因 #

加try块后错误响应慢的本质并非try块本身，而是EF Core数据库连接失败时的默认超时设置过长（默认约30秒）。未加try块时，异常会直接终止进程，你可能没感知到等待过程；加try块后会完整等待超时后捕获异常，所以显露出30秒的延迟。

具体优化方案 #

1. 提前快速验证数据库连接 #

在执行EF Core查询前，先通过原生SqlConnection做极短超时的连接验证，快速拦截配置错误：

using var conn = new SqlConnection(Configuration.GetConnectionString("YourDbConnection"));
var cts = new CancellationTokenSource(TimeSpan.FromSeconds(2));
try
{
    await conn.OpenAsync(cts.Token);
}
catch (OperationCanceledException)
{
    return new BadRequestObjectResult("数据库连接超时，请检查服务器配置");
}
catch (SqlException)
{
    return new BadRequestObjectResult("数据库配置错误，请核对服务器名称/权限");
}

此操作可在2秒内返回错误，无需等待EF Core默认超时。

2. 给EF Core查询设置超时限制 #

全局超时（DbContext配置）

在DbContext的OnConfiguring方法中设置全局命令超时：

protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
{
    optionsBuilder.UseSqlServer(
        Configuration.GetConnectionString("YourDbConnection"),
        opt => opt.CommandTimeout(5) // 全局设置5秒超时
    );
}

单次查询超时（EF Core 6+支持）

针对单个查询单独设置超时：

var table1Data = await _dbContext.Table1
    .Where(t => t.Status == 1)
    .Select(t => new Table1Dto { Id = t.Id, Name = t.Name })
    .WithTimeout(TimeSpan.FromSeconds(5))
    .ToListAsync();

3. 并行异步调用的超时控制 #

如果是并行执行多个异步查询，给所有任务设置统一超时，避免单个任务拖慢整体：

var cts = new CancellationTokenSource(TimeSpan.FromSeconds(5));
try
{
    // 并行启动所有查询任务
    var task1 = GetTable1DataAsync(cts.Token);
    var task2 = GetTable2DataAsync(cts.Token);
    var task3 = GetTable3DataAsync(cts.Token);

    await Task.WhenAll(task1, task2, task3);

    // 构建响应DTO
    var response = new 
    {
        Table1 = task1.Result,
        Table2 = task2.Result,
        Table3 = task3.Result
    };
    return new OkObjectResult(response);
}
catch (OperationCanceledException)
{
    return new StatusCodeResult(StatusCodes.Status504GatewayTimeout);
}
catch (SqlException ex)
{
    // 针对性处理SQL错误
    return new BadRequestObjectResult($"数据库错误：{ex.Message}");
}

4. 缩小try块范围，精准捕获异常 #

不要将整个函数逻辑包裹在try块中，仅对EF Core查询和DTO转换的核心代码做异常捕获，减少不必要的上下文：

// 非数据库操作的前置逻辑放在try块外
var requestParams = ParseRequestParameters(req);

try
{
    // 仅包裹数据库查询与DTO构建
    var table1Data = await _dbContext.Table1.Select(...).ToListAsync();
    var table2Data = await _dbContext.Table2.Select(...).ToListAsync();
    var response = new { Table1 = table1Data, Table2 = table2Data };
    return new OkObjectResult(response);
}
catch (SqlException ex) when (ex.Number == 18456)
{
    return new BadRequestObjectResult("数据库登录权限错误");
}
catch (SqlException ex) when (ex.Number == 4060)
{
    return new BadRequestObjectResult("指定数据库不存在");
}
catch (Exception)
{
    return new StatusCodeResult(StatusCodes.Status500InternalServerError);
}

5. 多DTO场景下的SQL查询优化（解决合并调用难题） #

无需强行合并成单条SQL查询，可通过批量多结果查询减少数据库连接次数，同时保留DTO的独立性：

// 执行多条SQL查询，一次性获取所有结果集
using var command = _dbContext.Database.GetDbConnection().CreateCommand();
command.CommandText = @"
    SELECT Id, Name FROM Table1 WHERE Status = 1;
    SELECT Id, Description FROM Table2 WHERE CreateTime > DATEADD(day, -7, GETDATE());
";
await _dbContext.Database.OpenConnectionAsync();
using var reader = await command.ExecuteReaderAsync();

// 手动拆分结果集并映射DTO
var table1DtoList = reader.Read() ? reader.MapToList<Table1Dto>() : new List<Table1Dto>();
reader.NextResult();
var table2DtoList = reader.Read() ? reader.MapToList<Table2Dto>() : new List<Table2Dto>();

（注：MapToList可通过AutoMapper的IMapper.Map<List<Table1Dto>>(reader)实现，或手动编写DataReader到DTO的映射逻辑）

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