async with 不能套 sync 的 contextlib.contextmanager,因为后者返回同步生成器,其 enter 和 exit 非异步方法,不满足 async with 要求的 aenter 和 aexit 协议。

async with 为什么不能套 sync 的 contextlib.contextmanager
因为 contextlib.contextmanager 返回的是同步生成器,它产生的 __enter__ 和 __exit__ 都是普通函数,无法 await。你写 async with 却传入一个同步上下文管理器,Python 会直接报 TypeError: async with requires an async context manager。
常见错误现象:把原来用 with open(...) 或 @contextmanager 写的资源管理逻辑,原封不动改成 async with,然后卡在启动阶段。
- 必须用
async def实现__aenter__和__aexit__,且类要继承abc.ABC或至少提供这两个方法 - 标准库中只有少数内置类型支持异步上下文,比如
aiofiles.open、aiomysql.Pool、httpx.AsyncClient - 自己写时别漏掉
await—— 比如在__aenter__里做连接初始化,不加await就会返回协程对象而非实际结果
async with 在数据库连接池里的典型误用
很多人以为只要用了 asyncpg.create_pool 或 aiomysql.create_pool,就能随便 async with pool.acquire(),但其实 acquire 是协程,必须 await;而 async with 只接管上下文协议,不自动 await 右值表达式。
使用场景:想每次请求复用连接,又避免手动 close。
立即学习“Python免费学习笔记(深入)”;
在原版的基础上做了一下修正评论没有提交正文的问题特价商品的调用连接问题去掉了一个后门补了SQL注入补了一个过滤漏洞浮动价不能删除的问题不能够搜索问题收藏时放入购物车时出错点放入购物车弹出2个窗口修正主题添加问题商家注册页导航连接问题销售排行不能显示更多问题热点商品不能显示更多问题增加了服务器探测 增加了空间使用查看 增加了在线文件编辑增加了后台管理里两处全选功能更新说明:后台的部分功能已经改过前台
- 正确写法是
async with await pool.acquire() as conn:—— 注意await在async with外层 - 错误写法:
async with pool.acquire() as conn:,这会让acquire()返回一个协程对象,触发RuntimeWarning: coroutine 'Pool.acquire' was never awaited - 某些旧版驱动(如早期 aiomysql)的
acquire()返回的是可等待对象,但没实现__aenter__,强行async with会报AttributeError: __aenter__
__aexit__ 里抛异常会导致 awaitable 被静默吞掉
如果在 __aexit__ 方法里主动 raise 异常,而调用方没有用 try/except 包住整个 async with 块,这个异常不会像同步那样中断后续代码流 —— 它会变成未处理的协程异常,在事件循环结束时才被打印(例如 uvicorn 日志末尾突然冒一行 Task exception was never retrieved)。
性能影响:这类异常不打断执行,但会污染日志、掩盖真正的问题源头。
-
__aexit__应该返回True来抑制异常,或返回None/False让异常继续向上冒泡 - 别在
__aexit__里做耗时操作(比如发 HTTP 请求),否则会阻塞整个协程退出路径 - 调试时可在
__aexit__开头加print(f"exiting with {exc_type}, {exc_value}"),确认是否真被调用了
和 asyncio.timeout 搭配时要注意作用域嵌套顺序
asyncio.timeout 是个异步上下文管理器,但它只对「同一层级」的 await 表达式生效。如果你把它套在 async with 外面,超时会中断整个块;但如果放在里面,就只保底单次操作。
使用场景:防止数据库查询卡死,但又不想让连接释放也超时。
- 推荐结构:
async with pool.acquire() as conn:→async with asyncio.timeout(5):→await conn.fetch(...) - 反模式:
async with asyncio.timeout(5): async with pool.acquire() as conn:—— 连接获取失败也会被 timeout 拦截,而 acquire 本身可能已经重试多次,此时 timeout 显得武断 - 注意
asyncio.timeout在 Python 3.11+ 才是稳定 API,旧版本要用asyncio.wait_for替代,但后者不是上下文管理器,不能直接用于async with
await,到中间的 async def,再到出口的异常传播控制。漏掉任一环,问题都藏得深。









