.NET Core控制台CosmosDB异步操作Task异常未捕获问题求解

1. 异常捕获类型不匹配：async/await 模式下，Task 内部的异常会自动解包抛出原始异常（比如 Cosmos DB 操作抛出的 CosmosException、空引用异常等），不会封装为 AggregateException。你仅捕获了 AggregateException，导致异步场景下的异常完全没被捕获，直接向上层抛出。
2. 控制台入口方法配置错误：如果你的控制台入口 Main 方法用了 async void 签名，异步方法执行过程中抛出的未捕获异常会触发未观察到的 Task 异常逻辑，导致进程直接退出，不会保留异常栈输出。如果是同步 void Main 里直接调用异步方法不加等待，也会出现进程在异步操作完成前就退出的问题。

调用 .Wait() 时，当前线程会同步阻塞等待 Task 执行完成，此时 Task 内部的异常会被包装为 AggregateException 抛出，刚好匹配你代码里的 catch (AggregateException) 逻辑，异常被捕获后打印输出，不会导致进程意外退出。

1. 修正 AddItemAsync 的异常捕获逻辑 #

增加通用异常捕获分支，覆盖异步场景下的异常，同时增加空校验避免空引用问题：

public async Task AddItemAsync(T item)
{
    try
    {
        Type myType = item.GetType();
        PropertyInfo propertyInfo = myType.GetProperty("Id");
        // 提前判空，避免后续操作抛出空引用异常
        if (propertyInfo == null || propertyInfo.GetValue(item) == null)
        {
            throw new InvalidOperationException("操作的实体缺少Id属性，或Id值为null");
        }
        await this._container.CreateItemAsync<T>(item,
            new PartitionKey(propertyInfo.GetValue(item).ToString()));
    }
    catch (AggregateException e)
    {
        // 仅同步调用.Wait()/.Result时触发
        Console.WriteLine($"同步调用异常：{e.Message}");
        // 如需上层处理异常，可在此处重新抛出：throw;
    }
    catch (Exception e)
    {
        // 异步await场景下的所有异常都会进入该分支
        Console.WriteLine($"异步调用异常：{e.Message}");
        // 如需上层处理异常，可在此处重新抛出：throw;
    }
}

2. 修正控制台入口方法签名 #

.NET 5 已经原生支持 async Task 类型的 Main 方法，使用该签名可以保证进程等待所有异步操作完成后再退出，也能正常捕获异步栈的异常：

class Program
{
    // 注意签名是 static async Task Main，不是 async void 也不是同步void
    static async Task Main(string[] args)
    {
        // 此处直接按异步写法调用即可
        using (StreamReader file = File.OpenText(@"Orgs.json"))
        {
            JsonSerializer serializer = new JsonSerializer();
            List<Org> org1 = (List<Org>)serializer.Deserialize(file, typeof(List<Org>));
            foreach (var org in org1)
            {
                await orgClient.AddItemAsync(org);
            }
        }
    }
}

3. 可选：上层增加异常捕获 #

如果需要在调用层处理异常，可以在外层套 try/catch 逻辑：

try
{
    foreach (var org in org1)
    {
        await orgClient.AddItemAsync(org);
    }
}
catch (Exception ex)
{
    Console.WriteLine($"业务处理失败：{ex.Message}");
}

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