异步会话提交报错后无法回滚，遇MissingGreenlet等异常问题

核心问题拆解 #

1. 为什么get_db捕获到的是PendingRollbackError而非HTTPException？ #

当你在do_something中捕获IntegrityError并抛出HTTPException时，Postgres已经因为约束冲突自动执行了ROLLBACK，此时SQLAlchemy的会话事务处于失败未重置的状态。当yield session结束、会话即将被关闭时，SQLAlchemy会自动检查事务状态，发现事务未被正确回滚，就会抛出PendingRollbackError——这个错误是在业务代码执行完毕后触发的，因此会被get_db的except块捕获，而非你抛出的HTTPException。

2. 为什么手动调用await session.rollback()会触发MissingGreenlet？ #

SQLAlchemy的异步会话操作依赖于特定的greenlet上下文（由SQLAlchemy的异步扩展和asyncio协同管理）。当yield session结束后，当前代码的执行上下文已经脱离了请求处理的greenlet链，此时调用await session.rollback()会因为找不到有效的greenlet上下文而抛出MissingGreenlet错误。

3. 不调用rollback为什么会返回500错误？ #

如果不手动回滚，SQLAlchemy在会话关闭前会强制检查事务状态，发现事务处于失败未处理状态时，会主动抛出PendingRollbackError，这个未被捕获的错误会导致服务器返回500状态码。

解决方案 #

方案一：在业务代码中完成回滚（推荐） #

既然已经在业务逻辑中捕获了已知的异常，直接在异常处理块中回滚事务，确保会话状态正常：

async def do_something(db=Depends(get_db)):
    try:
        await db.commit() # 因唯一约束冲突抛出IntegrityError
    except IntegrityError as e:
        logger.error(f"Caught error {e}")
        await db.rollback()  # 手动回滚事务，重置会话状态
        raise HTTPException(400, "UniqueConstraintViolation")

这样处理后，会话在返回给get_db时状态正常，不会触发PendingRollbackError，get_db的finally块只需正常关闭会话即可。

方案二：在get_db中适配异常处理 #

如果需要在会话管理器中统一处理，可针对PendingRollbackError做特殊处理——因为此时事务已经被Postgres自动回滚，无需再手动调用rollback：

from sqlalchemy.exc import PendingRollbackError

async def get_db(self) -> AsyncIterator[AsyncSession]:
    session = self.scoped_session()
    try:
        yield session
    except PendingRollbackError:
        # 事务已被数据库自动回滚，无需额外操作
        pass
    except Exception as e:
        # 处理其他未预期的异常
        raise
    finally:
        await session.close()

这种方式适合处理未在业务代码中捕获的异常，但推荐优先在业务层处理已知异常并回滚，保持会话管理器的简洁性。

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