Python中如何捕获异步任务中的所有异常_利用gather的return

asyncio.gather()需设return_exceptions=true才能继续执行并收集全部结果，此时异常对象会作为列表元素返回，需用isinstance(r, baseexception)判别，结果顺序与输入严格一致。

python中如何捕获异步任务中的所有异常_利用gather的return_exceptions参数

gather 抛出第一个异常就中断，怎么让它继续执行并收集全部结果

默认情况下，asyncio.gather() 遇到任一协程抛出异常，会立即取消其余未完成任务，并把第一个异常直接抛出。这和“想看所有任务成败结果”的需求冲突——比如批量调用 API、并发验证多个配置项，你得知道哪几个失败了、各自错在哪。

关键解法就是启用 return_exceptions=True 参数。它会让 gather() 把异常对象也当作正常返回值塞进结果列表，而不是提前中断。

不加该参数：只要有一个 ValueError，其他还在跑的任务全被 cancel，你只拿到一个 ValueError
加了 return_exceptions=True：所有协程无论成功失败都跑完，结果列表里对应位置是 str、int 或 ValueError 实例

如何区分结果里的异常对象和正常返回值

启用了 return_exceptions=True 后，gather() 返回的是混合类型列表，必须手动判断每个元素是不是异常。不能靠 isinstance(x, Exception) 就完事——因为有些协程可能真返回了一个 Exception 实例（虽然少见，但合法）；更稳妥的方式是检查是否为异常实例且未被处理过。

推荐做法：用 isinstance(x, BaseException) 判断（BaseException 是所有异常的基类，包括 Exception 和 KeyboardInterrupt 等）
注意：asyncio.CancelledError 也会被包裹进来，如果任务被外部取消，它也会出现在结果中
实际校验时建议搭配 traceback.format_exception() 提取错误上下文，而不是只打印 str(e)

示例片段：

python-pro

高级 Python 特性、异步编程、性能调优、静态类型、内存管理、Python 内部机制及生态库方面的专家。

下载

import asyncio

async def may_fail(n):
    if n == 2:
        raise ValueError("n is 2")
    return f"done-{n}"

async def main():
    tasks = [may_fail(i) for i in [0, 1, 2, 3]]
    results = await asyncio.gather(*tasks, return_exceptions=True)
    for i, r in enumerate(results):
        if isinstance(r, BaseException):
            print(f"Task {i} failed: {type(r).__name__}: {r}")
        else:
            print(f"Task {i} succeeded: {r}")

asyncio.run(main())