实体框架查询失败“任务已取消。”

Question

我有一个 ASP Core 3.1 Web 项目，我想在其中添加 EntityFramework Core。
我创建了一个 db 上下文、具有数据库操作的模型类，并将其注入到我的主类（Azure Bot）中。

但是，当我尝试将记录插入数据库时​​，它总是失败并显示错误

System.Threading.Tasks.TaskCanceledException: '任务已取消。'

这是我的 startup.cs：

services.AddDbContext<IVRContext>(options =>
            options.UseSqlServer(
                Configuration.GetConnectionString("DefaultConnection"),
                optionBuilder => optionBuilder.EnableRetryOnFailure()
            )
        );
        services.AddTransient<IVRCallModel>();

这是我正在调用的 IVRModel 中的函数：

 public async Task InsertCallAsync(IVRCall call)
    {
        try
        {
            await _ivrContext.Calls.AddAsync(call);
            await _ivrContext.SaveChangesAsync();
        }
        catch (Exception ex)
        {
            throw new Exception(ex.Message, ex);
        }
    }

我是这样称呼它的：

private async Task NotificationProcessor_OnNotificationReceivedAsync(NotificationEventArgs args)
{
    this.GraphLogger.CorrelationId = args.ScenarioId;
    if (args.ResourceData is Call call)
    {
        if (call.Direction != CallDirection.Outgoing && call.ToneInfo == null)
        {
            if (args.ChangeType == ChangeType.Created && call.State == CallState.Incoming)
            {
                await SaveCall(call.Id, call.CallChainId, "Incoming");
                
                .... code removed 
            }
        }
    }
}

private async Task SaveCall(string callId, string callChainId, string callState, string redirectCallId = null)
{
    IVRCall newCall = new IVRCall();
    newCall.Id = callId;
    newCall.CallChainId = callChainId;
    newCall.TimeStamp = DateTime.Now.ToString("dd-MM-yyyy HH:mm:ss");
    newCall.State = callState;
    newCall.RedirectCallId = redirectCallId; 
    await _ivrCallModel.InsertCallAsync(newCall);
}

编辑： “原始” NoticicationProcessor_OnNotificationReceived 函数，它调用异步方法。 （来自 Microsoft 示例项目）

private void NotificationProcessor_OnNotificationReceived(NotificationEventArgs args)
{
    _ = NotificationProcessor_OnNotificationReceivedAsync(args).ForgetAndLogExceptionAsync(this.GraphLogger, $"Error processing notification {args.Notification.ResourceUrl} with scenario {args.ScenarioId}");
}

Answer 1

当代码在响应已发送到客户端后尝试运行时，将发生该异常。当您使用 async/await 时，可能会在某处未等待异步的情况下发生这种情况。

确实，这里正在发生这种情况：

private void NotificationProcessor_OnNotificationReceived(NotificationEventArgs args)
{
    _ = NotificationProcessor_OnNotificationReceivedAsync(args).ForgetAndLogExceptionAsync(this.GraphLogger, $"Error processing notification {args.Notification.ResourceUrl} with scenario {args.ScenarioId}");
}

当await 作用于不完整的Task 时，它实际上会返回。它返回一个自己的Task，以便调用者可以跟踪它何时完成。因此，当NotificationProcessor_OnNotificationReceivedAsync 返回时，工作实际上并未完成。而且因为您没有使用Task，所以会继续执行，ASP.NET 会包装请求并结束该请求的任务。

在异步代码中使用事件处理程序可能会很棘手，尤其是在这种情况下，您需要在工作完成之前暂停执行，否则您会得到意想不到的结果。您可以使用 .GetAwaiter().GetResult() 之类的东西在异步代码上同步等待，但这可能会产生意想不到的后果。

我认为你最好的办法是在这种情况下只使用同步代码：使用 .SaveChanges() 而不是 .SaveChangesAsync()。

关于你使用.AddAsync()，the documentation 说：

此方法是异步的，仅允许特殊值生成器（例如“Microsoft.EntityFrameworkCore.Metadata.SqlServerValueGenerationStrategy.SequenceHiLo”使用的值生成器）异步访问数据库。对于所有其他情况，应使用非异步方法。

所以你应该一直只使用.Add()，即使在异步方法中也是如此。

关于您的try/catch 块的评论也是有效的。如果您要捕获一个异常只是为了使用相同的消息抛出一个新异常，那么根本不要捕获该异常。即使您需要在再次抛出异常之前进行一些日志记录或其他操作，也请仅使用 throw; 而不是 throw new Exception(ex.Message, ex);。抛出新异常会更改异常发生位置的堆栈跟踪，并可能使调试变得困难。