SQLAlchemy异步查询抛出GreenletExit是因为在非协程环境（如同步函数、普通线程）中await异步操作，导致greenlet上下文失效；必须全程使用async/await，确保引擎、Session类型、事件循环一致。
SQLAlchemy异步查询为什么抛出 greenlet.GreenletExit？
这不是你代码写错了，而是 SQLAlchemy 异步驱动（如 asyncpg 或 aiomysql）底层依赖 greenlet 实现协程上下文切换，而你在非 greenlet 环境中（比如普通线程、同步函数里）直接 await 了异步查询，就会触发 GreenletExit —— greenlet 检测到当前上下文不合法，主动中止执行。
常见诱因包括：
- 在普通
def函数里调用await session.execute(...) - 用
threading.Thread启动异步任务，但没用asyncio.run()或事件循环管理 - FastAPI 路由用了
def而非async def，却在里面 await 异步 ORM 操作 - 在 Jupyter Notebook 中未启用 async 支持（如没调用
await或用%run错误执行）
必须确保整个调用链都是 async/await
SQLAlchemy 的异步支持不是“局部可插拔”的，它要求从入口函数开始就是协程，并且所有中间层（包括依赖注入、工具函数、日志包装等）都不能切断 await 链。
正确写法示例（FastAPI 场景）：
立即学习“Python免费学习笔记（深入）”；
@app.get("/users")
async def get_users(session: AsyncSession = Depends(get_session)):
stmt = select(User).where(User.active == True)
result = await session.execute(stmt) # ✅ 在 async def 内 await
users = result.scalars().all()
return users
错误写法示例：
@app.get("/users")
def get_users(session: AsyncSession = Depends(get_session)): # ❌ def 不行
result = await session.execute(...) # 这行会直接报 GreenletExit
关键检查点：
- 路由函数、服务函数、数据库访问函数，全部必须是
async def - 不要在
sync函数里调用async函数并试图用asyncio.run()包裹——这会新建 event loop，与异步驱动绑定的 loop 冲突 - 依赖注入（如 FastAPI 的
Depends）返回的AsyncSession必须在 async 上下文中使用
别混用 sync 和 async 的 Session 类型
SQLAlchemy 2.0+ 中，Session 和 AsyncSession 完全不兼容。用错类型不会立刻报错，但一执行查询就可能触发 greenlet 相关异常或静默失败。
典型错误：
- 配置了
create_async_engine，却注入了Session（同步类） - 在
AsyncSession上调用.commit()而不是.commit()的 await 版本（即await session.commit()） - 用
session.query(...)（已废弃且仅同步可用）代替await session.execute(select(...))
务必核对初始化逻辑：
# ✅ 正确：异步引擎 + 异步 Session 类
engine = create_async_engine("postgresql+asyncpg://...")
AsyncSessionLocal = sessionmaker(engine, class_=AsyncSession)
<h1>❌ 错误：用同步 sessionmaker 包异步引擎</h1><p>SessionLocal = sessionmaker(engine) # 即使 engine 是 async 的，这里也失效
测试脚本里容易漏掉 asyncio.run()
独立 Python 脚本或单元测试中，最容易忽略的是：没有显式启动事件循环。直接运行 await ... 会报 RuntimeError: no running event loop，而有些环境（如旧版 IPython）会退化为 greenlet 错误。
安全写法：
import asyncio
from sqlalchemy.ext.asyncio import create_async_engine, AsyncSession
<p>async def main():
engine = create_async_engine("sqlite+aiosqlite:///./test.db")
async with AsyncSession(engine) as session:
result = await session.execute(text("SELECT 1"))
print(result.scalar())</p><p>if <strong>name</strong> == "<strong>main</strong>":
asyncio.run(main()) # ✅ 必须包一层
注意：asyncio.run() 不能嵌套调用；若已在某个 event loop 中（如 FastAPI 启动后），再调用它会报错。开发期脚本和测试用它没问题，生产 Web 服务中交给框架管理即可。
greenlet 错误背后往往不是 greenlet 本身的问题，而是 async 执行环境被意外破坏——比如跨线程、loop 错配、或同步/异步对象混用。盯住事件循环生命周期和 Session 类型一致性，比调 greenlet 参数更有效。
