讲师中心 微信公众号

工具推荐

视频效率加速
Seko
Seko

AI短剧一键生成成片

Laper
Laper

剧本策划到成片协作

updream

一键生成高质量推广成片

立刻MV
立刻MV

低成本歌曲 MV、视频生成

FastAPI怎么使用SQLAlchemy进行异步数据库操作

雨磊君_7075

雨磊君_7075

发布时间:2026-11-10 10:08:30

|

219人浏览过

|

来源于php中文网

原创

create_async_engine 是起点,不是终点;必须严格匹配异步驱动与连接串协议、用 async with 管理 AsyncSession 生命周期、继承 DeclarativeBase 并使用 Mapped 定义模型、显式调用 commit/rollback 控制事务。

fastapi怎么使用sqlalchemy进行异步数据库操作

create_async_engine 是起点,不是终点。用错驱动、漏关会话、混用同步写法,接口照样卡死。

确认数据库驱动是否真正异步

常见错误是装了 aiomysql 却用 mysql+pymysql:// 连接串,或反过来装 asyncmy 却配 mysql+aiomysql://。两者不兼容,启动时可能无报错,但首次查询直接抛 RuntimeError: This event loop is already running 或静默阻塞。

必须严格匹配:

  • mysql+aiomysql:// → 依赖 aiomysql
  • mysql+asyncmy:// → 依赖 asyncmy
  • postgresql+asyncpg:// → 依赖 asyncpg

检查命令:pip list | grep -i "aiomysql\|asyncmy\|asyncpg";连接串中协议前缀必须与已安装驱动一致。

AsyncSession 必须用 async with 管理生命周期

这是最常被忽略的坑。直接写 session = AsyncSessionLocal() 然后 await session.execute(...),会导致连接永不归还池,跑几轮压测就 TimeoutError: QueuePool limit of size 10 overflow 20 reached。

正确姿势只有一种:

async def get_user(user_id: int, session: AsyncSession = Depends(get_db)):
    result = await session.execute(select(User).where(User.id == user_id))
    return result.scalar_one_or_none()

其中 get_db 必须是:

async def get_db():
    async with AsyncSessionLocal() as session:
        yield session

注意:yield 不可省略,async with 不可替换成 sessionmaker 直接调用。

FastAPI Flask Proxy
FastAPI Flask Proxy

FastAPI + Flask 混合部署最佳实践,解决路由定义、API 代理等常见问题,适用于同时运行 FastAPI API 与 Flask 前端的场景。

下载

模型定义必须用 DeclarativeBase + Mapped

SQLAlchemy 2.0 异步模式下,老式 Column() 配合 declarative_base() 虽然能跑,但 await session.merge() 或 await session.refresh() 会报 AttributeError: 'AsyncSession' object has no attribute 'merge' —— 实际是模型没继承对基类。

务必使用:

from sqlalchemy.orm import DeclarativeBase, Mapped, mapped_column

class Base(DeclarativeBase):
    pass

class User(Base):
    __tablename__ = "users"
    id: Mapped[int] = mapped_column(primary_key=True)
    name: Mapped[str] = mapped_column(String(50))

不要用 from sqlalchemy.ext.declarative import declarative_base,那是 1.x 时代的同步写法,和异步会话不完全兼容。

事务边界必须显式控制

FastAPI 默认每个请求一个 AsyncSession,但 commit() 和 rollback() 不会自动触发。你写 await session.add(user) 后不 await session.commit(),数据就只是暂存在会话里,请求结束即丢弃。

典型错误流程:

  • POST 创建用户 → add + flush(想取 ID)→ 但没 commit
  • 紧接着 GET 查询 → 查不到,因为事务未提交

解决方案只有两个:

  • 明确需要持久化:在业务函数末尾加 await session.commit()
  • 只想查或临时操作:用 session.begin_nested() 做保存点,避免污染主事务

别指望依赖注入自动 commit —— 它只管开和关会话,不管你的业务逻辑要不要存。

异步不是加个 async/await 就完事。驱动、基类、会话管理、事务控制,四个环节任一错位,都会让 FastAPI 的异步能力归零。尤其 async with 和 Mapped 这两点,90% 的线上问题都出在这儿。

热门AI工具

更多
音述AI
音述AI Hot

一款AI音频处理工具,主要用于音述AI是一个以“用声音述说故事”为核心的 AI 音乐创作与声音分享社区,适合需要提升相关任务效率的用户。

蛙蛙写作

一款AI论文写作工具,主要用于超级AI智能写作助手,适合需要提升相关任务效率的用户。

咔片AIPPT

一款在线AI演示文稿制作工具,可根据主题和内容需求辅助生成PPT结构与页面,提高演示材料制作效率。

SkildArt
SkildArt Hot

SkildArt是一款AI文本写作工具,一站式 AI 视觉创作平台。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

VibeKnow
VibeKnow Hot

一款AI视频创作工具,主要用于全球首个AI知识视频创作平台,文档、文章、网页,一键生成视频,适合需要提升相关任务效率的用户。

UpDream
UpDream Hot

一款AI视频创作工具,主要用于哔哩哔哩推出的自研AI视频创作工具,适合需要提升相关任务效率的用户。

相关专题

更多
Python FastAPI异步API开发_Python怎么用FastAPI构建异步API
Python FastAPI异步API开发_Python怎么用FastAPI构建异步API

Python FastAPI 异步开发利用 async/await 关键字,通过定义异步视图函数、使用异步数据库库 (如 databases)、异步 HTTP 客户端 (如 httpx),并结合后台任务队列(如 Celery)和异步依赖项,实现高效的 I/O 密集型 API,显著提升吞吐量和响应速度,尤其适用于处理数据库查询、网络请求等耗时操作,无需阻塞主线程。

119

2025.12.22

Python 微服务架构与 FastAPI 框架
Python 微服务架构与 FastAPI 框架

本专题系统讲解 Python 微服务架构设计与 FastAPI 框架应用,涵盖 FastAPI 的快速开发、路由与依赖注入、数据模型验证、API 文档自动生成、OAuth2 与 JWT 身份验证、异步支持、部署与扩展等。通过实际案例,帮助学习者掌握 使用 FastAPI 构建高效、可扩展的微服务应用,提高服务响应速度与系统可维护性。

574

2026.02.06

Python Web框架FastAPI 全栈开发教程合集
Python Web框架FastAPI 全栈开发教程合集

以 FastAPI 为核心,讲解现代 Python Web API 的高效开发方式,涵盖路由定义与路径参数/查询参数/请求体绑定、Pydantic 模型的数据校验与序列化、依赖注入(Depends)系统的分层设计、中间件与 CORS 配置、OAuth2 + JWT 认证流程、后台任务(BackgroundTasks)、WebSocket 实时通信、SQLAlchemy 异步 ORM 集成、自动生成 OpenAPI/Swagger 交互文

736

2026.05.09

Python FastAPI异步微服务与高性能接口设计
Python FastAPI异步微服务与高性能接口设计

本专题聚焦 Python FastAPI 框架在高性能接口与微服务开发中的应用,讲解异步请求处理、依赖注入机制、路由设计、数据库异步操作以及接口性能优化策略。结合实际项目案例,帮助开发者构建高并发、低延迟的现代化后端服务架构。

619

2026.06.16

Postman身份认证怎么配置
Postman身份认证怎么配置

本专题从实际API接口调试场景出发,讲解Postman身份认证的完整配置流程,包括常见认证协议介绍、授权参数设置、访问令牌填写、OAuth 2.0授权及认证失败排查,帮助用户正确完成接口授权与访问验证。

60

2026.11.06

Postman请求头Headers怎么设置
Postman请求头Headers怎么设置

围绕Postman HTTP请求头配置展开,讲解Headers选项的具体使用方式,包括Key和Value参数填写、请求头信息添加、常见Header字段设置及请求头修改方法,帮助用户解决接口调试过程中遇到的请求头配置问题。

20

2026.11.06

Postman接口请求发送教程
Postman接口请求发送教程

详细介绍Postman接口请求的创建与发送方法,涵盖GET和POST请求、URL配置、请求参数、Headers请求头、Body请求体设置以及响应结果查看,帮助用户掌握Postman接口请求的完整操作流程。

20

2026.11.06

DBeaver怎么导入数据
DBeaver怎么导入数据

DBeaver数据导入专题,整理Excel、CSV、SQL、TXT等常见文件的数据导入方法,涵盖目标数据库选择、数据表创建、字段映射、数据类型设置及导入参数配置等操作,帮助用户将本地文件中的数据写入数据库,并了解批量导入、重复数据处理和导入失败等常见问题的解决方法。

40

2026.11.05

DBeaver安全防护教程大全
DBeaver安全防护教程大全

DBeaver安全防护专题,围绕数据库连接安全、账号密码保护和访问权限管理展开,整理SSL/TLS加密连接、SSH隧道、数据库凭据保存及证书验证等配置方法,同时介绍敏感信息保护、远程连接风险和高权限账号使用等注意事项,帮助用户提高数据库日常管理的安全性。

40

2026.11.05

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
DBeaver生态工具dbvr官方手册
DBeaver生态工具dbvr官方手册

共0课时 | 0人学习

DBeaver AI数据隐私指南
DBeaver AI数据隐私指南

共0课时 | 0人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn