Cosmos DB使用async/await时程序静默退出，同步调用正常

问题描述 #

我这段代码执行时会静默退出：

public async Task<IList<T>> ByAsync<T>(Expression<Func<T, bool>> predicate = null) where T : class
{
    var query = containerProvider.GetContainer<T>().GetItemLinqQueryable<T>();
    var iterator = (predicate != null) ? query.Where(predicate).ToFeedIterator<T>() : query.ToFeedIterator<T>();
    using (iterator)
    {
        var results = new List<T>();
        while (iterator.HasMoreResults)
        {
            // 错误：这里永远不返回，代码直接静默退出
            var response = await iterator.ReadNextAsync();
            results.AddRange(response);
        }

        return results;
    }
}

如果把var response = await iterator.ReadNextAsync();改成var response = iterator.ReadNextAsync().GetAwaiter().GetResult();就能正常运行，但这种方式并不理想。而且执行upsert操作时也会出现同样的问题，就像async/await机制失效了一样。我本地用的是Cosmos DB模拟器，.NET客户端版本是3.39.1，不知道该怎么解决，有没有人遇到过类似问题，或者我哪里操作错了？

我原本想用var response = await iterator.ReadNextAsync();获取响应，但程序直接静默退出，甚至用try/catch都捕获不到错误。

解决方案及排查方向 #

1. 同步异步混用导致死锁
   你用GetAwaiter().GetResult()能正常运行，核心原因大概率是上层调用代码用了同步阻塞方式（比如.Wait()/.Result()）等待异步方法，导致上下文死锁。Cosmos DB的异步API要求全调用链异步，不能在同步代码中强行阻塞异步任务。

• 解决：确保调用ByAsync的所有上层代码都使用await，从入口到该方法的整个调用链路保持异步，彻底移除同步阻塞的代码。

2. 异常捕获逻辑不完善
   虽然你提到try/catch无法捕获错误，但可能是异常发生在异步流的其他环节，或者没有正确包裹异步执行逻辑。可以把ReadNextAsync的调用放到try/catch块中，同时显式检查响应状态：

while (iterator.HasMoreResults)
{
    try
    {
        var response = await iterator.ReadNextAsync();
        if (!response.IsSuccessStatusCode)
        {
            throw new InvalidOperationException($"Cosmos查询失败，状态码：{response.StatusCode}，详情：{response.ErrorMessage}");
        }
        results.AddRange(response);
    }
    catch (Exception ex)
    {
        // 记录完整异常信息（包括堆栈）
        Console.WriteLine($"查询异常：{ex.Message}\n{ex.StackTrace}");
        throw; // 重新抛出异常让上层处理
    }
}

3. 客户端或模拟器版本问题
   你使用的3.39.1版本并非最新稳定版，可能存在异步API的已知bug。建议：

• 升级Cosmos DB .NET客户端到最新的v3.x稳定版
• 更新本地Cosmos DB模拟器至最新版本，再重新测试

4. 容器实例或迭代器使用问题

• 确认containerProvider.GetContainer<T>()返回的容器实例有效，没有在其他逻辑中被提前释放
• 检查是否在迭代器运行过程中，有其他代码修改了容器或查询上下文

额外排查建议 #

• 开启Cosmos客户端日志，查看底层请求的详细交互过程：

// 构建CosmosClient时配置日志
var cosmosClient = new CosmosClient(connectionString, new CosmosClientOptions
{
    LoggerFactory = LoggerFactory.Create(builder =>
    {
        builder.AddConsole();
        builder.SetMinimumLevel(LogLevel.Debug);
    })
});

• 检查应用全局异常处理机制：控制台应用订阅AppDomain.CurrentDomain.UnhandledException事件，ASP.NET Core配置app.UseExceptionHandler，确保异步线程的异常能被捕获记录。

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