Python 异步异常传播的常见陷阱

1次阅读

async/await异常不会自动冒泡,未await的协程异常会静默滞留;task.cancel()仅设标记需手动响应;gather()默认传播首个异常;未读取task.exception()会导致异常隐藏。

Python 异步异常传播的常见陷阱

async/await 中的异常不会自动冒泡到外层

调用 async 函数返回的是一个 coroutine 对象,不是立即执行——这意味着你没 await 它,异常根本不会抛出,连 traceback 都看不到。常见于忘记 await 一个异步函数,或者误把它当同步函数直接调用。

实操建议:

立即学习Python免费学习笔记(深入)”;

  • 所有 async 函数调用必须显式 await,除非你明确要延迟执行(比如放进 asyncio.create_task()
  • pytestunittest 测试异步函数时,测试方法本身也得是 async def 并用 await 调用被测函数
  • pycharm 和 VS Code 的 linter(如 Pylint、Ruff)能识别未 await 的 coroutine,开启 async-await 相关检查项

Task.cancel() 不会立即终止协程执行

asyncio.Task.cancel() 只是设个标记并抛出 CancelledError,协程得自己响应这个异常才能退出。如果协程里有阻塞调用(比如没加 timeout 的 await asyncio.sleep() 或网络请求),它可能卡住,甚至让整个事件循环僵住。

实操建议:

立即学习Python免费学习笔记(深入)”;

  • 在关键协程中用 try/except CancelledError 捕获,并做清理(如关闭连接、释放资源)
  • 避免在 finally 块里写耗时操作;若必须,用 asyncio.wait_for(..., timeout=...) 包裹
  • 取消后记得 await task 等待它真正结束,否则 CancelledError 会被压制,后续无法感知是否已清理完成

asyncio.gather() 默认不传播异常

asyncio.gather(*coros, return_exceptions=False) 在任一子协程出错时,会立刻取消其余任务,并把第一个异常原样抛出——但前提是没设 return_exceptions=True。很多人开了这个参数却忘了处理返回值里的 Exception 实例,结果逻辑静默失败。

实操建议:

立即学习Python免费学习笔记(深入)”;

  • 默认保持 return_exceptions=False,让异常尽早暴露;仅在“允许部分失败”场景才开它
  • 若开了 return_exceptions=True,务必检查每个返回值:isinstance(x, Exception),不能直接解包或调用方法
  • asyncio.gather() 的异常类型和深度受子协程影响,调试时注意看 __cause____context__

未 await 的异常会滞留在 Task 对象里

asyncio.create_task() 启动协程后,如果不 await 它、也不调用 task.exception(),里面发生的异常就一直挂着,既不打印也不传播。python 3.12 开始会在解释器退出时警告,但更早版本完全静默。

实操建议:

立即学习Python免费学习笔记(深入)”;

  • 所有 create_task() 后,要么 await task,要么至少调用 task.exception() 主动读取一次
  • 生产环境建议用 asyncio.create_task(..., name="xxx") 命名任务,方便日志追踪和调试
  • 别依赖 asyncio.all_tasks() 手动轮询——容易漏掉刚创建还没调度的 task,优先用结构化并发(如 asyncio.TaskGroup

异步异常最麻烦的不是它多难捕获,而是它能在你完全没察觉的情况下消失或错位。尤其要注意那些“看起来运行了但没报错”的协程——它们很可能正带着异常卡在某个 Task 里,等你重启服务时才突然爆发。

text=ZqhQzanResources