• FastAPI + Tortoise-ORM:异步数据库操作优秀实践

FastAPI + Tortoise-ORM:异步数据库操作优秀实践

2025-04-27 10:40:52 栏目:宝塔面板 450 阅读

在构建现代 Web 应用时,我们越来越追求 高性能 + 易维护 + 强扩展性。FastAPI 与 Tortoise-ORM 这对组合,正是实现 异步数据库操作 的黄金搭档。

本文将带你一步步搞定:

  • Tortoise-ORM 快速配置与初始化
  • 异步模型定义与操作
  • 项目结构推荐
  • 实用技巧与注意事项

为什么选 Tortoise-ORM?

Tortoise-ORM 是一个 类 Django 风格的异步 ORM,优雅 + 轻量 + 高性能。

优点包括:

  • 原生支持 async / await,异步性能更佳
  • 语法清晰,易于上手
  • 支持多数据库(PostgreSQL、MySQL、SQLite)
  • 自带迁移工具、强类型提示、关系管理

安装依赖

pip install fastapi[all] tortoise-orm

如果你使用 Alembic 等迁移工具,可以跳过,Tortoise 自带 aerich:

pip install aerich

目录结构推荐

app/
├── main.py              # 项目入口
├── models/              # 数据模型
│   └── user.py
├── schemas/             # Pydantic 模型
│   └── user.py
├── api/                 # 路由逻辑
│   └── user.py
├── core/
│   └── config.py        # 配置项
│   └── db.py            # 数据库初始化

定义模型(models/user.py)

from tortoise import fields
from tortoise.models import Model

class User(Model):
    id = fields.IntField(pk=True)
    name = fields.CharField(max_length=50)
    email = fields.CharField(max_length=100, unique=True)

    class Meta:
        table = "user"

配置数据库连接(core/db.py)

from tortoise.contrib.fastapi import register_tortoise
from fastapi import FastAPI

def init_db(app: FastAPI):
    register_tortoise(
        app,
        db_url="sqlite://db.sqlite3",  # 可替换为 mysql/postgres
        modules={"models": ["app.models.user"]},  # 关键点
        generate_schemas=True,  # 启动时自动创建表
        add_exception_handlers=True
    )

说明:

  • modules={"models": ["app.models.user"]} 指定模型路径(可传多个)
  • 会自动导入并注册这些模型

初始化数据库(main.py)

from fastapi import FastAPI
from app.core.db import init_db
from app.api import user

app = FastAPI()

init_db(app)  # 初始化 ORM

app.include_router(user.router)

编写接口(api/user.py)

from fastapi import APIRouter, HTTPException
from app.models.user import User
from app.schemas.user import UserIn, UserOut

router = APIRouter()

@router.post("/users", response_model=UserOut)
asyncdefcreate_user(user: UserIn):
    existing = await User.get_or_none(email=user.email)
    if existing:
        raise HTTPException(status_code=400, detail="邮箱已存在")
    user_obj = await User.create(**user.dict())
    return user_obj

@router.get("/users/{user_id}", response_model=UserOut)
asyncdefget_user(user_id: int):
    user = await User.get_or_none(id=user_id)
    ifnot user:
        raise HTTPException(status_code=404, detail="用户不存在")
    return user

Pydantic 模型(schemas/user.py)

from pydantic import BaseModel, EmailStr

class UserIn(BaseModel):
    name: str
    email: EmailStr

class UserOut(UserIn):
    id: int

使用 Aerich 管理迁移(可选)

初始化:

aerich init -t app.core.db.TORTOISE_ORM

生成迁移:

aerich init-db
aerich migrate
aerich upgrade

使用建议 & 常见问题

推荐做法:

  • 所有 ORM 操作都使用 await
  • 异步接口必须加 async def
  • 初始化模块路径必须写对,否则不会加载模型
  • 不建议手动写 SQL,除非非常必要

常见坑:

  • 没注册模型路径,表不会生成!
  • await 忘写,会返回协程对象
  • 生产环境请关闭 generate_schemas=True,使用迁移工具更稳

总结

FastAPI + Tortoise-ORM 能让你拥有:

  • 异步数据库高性能
  • 简洁优雅的模型定义
  • 良好的开发体验与类型安全

如果你追求异步、类型提示、快速开发,这是非常值得一试的组合!

本文地址:https://www.yitenyun.com/114.html

搜索文章

Tags

数据库 API FastAPI Calcite 电商系统 MySQL Web 应用 异步数据库 数据同步 ACK 双主架构 循环复制 TIME_WAIT 运维 负载均衡 JumpServer SSL 堡垒机 跳板机 HTTPS HexHub Docker 服务器 管理口 服务器性能 JumpServer安装 堡垒机安装 Linux安装JumpServer Deepseek 宝塔面板 Linux宝塔 生命周期 esxi esxi6 root密码不对 无法登录 web无法登录 SQL 查询 序列 核心机制 Windows Windows server net3.5 .NET 安装出错 HTTPS加密 Windows宝塔 Mysql重置密码 开源 PostgreSQL 存储引擎 锁机制 宝塔面板打不开 宝塔面板无法访问 查看硬件 Linux查看硬件 Linux查看CPU Linux查看内存 行业 趋势 Oracle 处理机制 无法访问宝塔面板 Undo Log 机制 Spring Redis 异步化 监控 优化 万能公式 连接控制 InnoDB 数据库锁 机器学习 动态查询 Serverless 无服务器 语言 ES 协同 响应模型 group by 索引 技术 openHalo 分页查询 scp Linux的scp怎么用 scp上传 scp下载 scp命令 缓存方案 缓存架构 缓存穿透 Postgres OTel Iceberg 工具 高可用 存储 GreatSQL 连接数 数据 主库 SVM Embedding R edis 线程 日志文件 MIXED 3 国产数据库 Linux 安全 R2DBC Netstat Linux 服务器 端口 SQLite-Web SQLite 数据库管理工具 加密 场景 启动故障 ​Redis 推荐模型 Recursive 自定义序列化 防火墙 黑客 云原生 SQLark RocketMQ 长轮询 配置 共享锁 向量数据库 大模型 OB 单机版 AI 助手 PG DBA Hash 字段 Rsync 信息化 智能运维 Ftp 磁盘架构 不宕机 电商 系统 向量库 Milvus 数据分类 架构 Canal Python 修改DNS Centos7如何修改DNS 业务 IT运维 流量 • 索引 • 数据库 传统数据库 向量化 线上 库存 预扣 filelock 分库 分表 MVCC 语句 MySQL 9.3 sftp 服务器 参数 PostGIS mini-redis INCR指令 人工智能 推荐系统 redo log 重做日志 同城 双活 聚簇 非聚簇 频繁 Codis 失效 Doris SeaTunnel MongoDB MCP 开放协议 缓存 Redisson 锁芯 高效统计 今天这篇文章就跟大家 工具链 事务 Java 开发 主从复制 代理 数据类型 虚拟服务器 虚拟机 内存 INSERT COMPACT prometheus Alert 数据备份 千万级 大表 数据结构 ZODB 窗口 函数 网络架构 网络配置 发件箱模式 SSH 容器 QPS 高并发 EasyExcel MySQL8 引擎 性能 Web 分布式架构 分布式锁​ 聚簇索引 非聚簇索引 崖山 新版本 数据脱敏 加密算法 B+Tree ID 字段 分布式 集中式 RDB AOF 核心架构 订阅机制 Go 数据库迁移 Redis 8.0 分页 速度 服务器中毒 Web 接口 播客 OAuth2 Token 数据页 数据集成工具 读写 自动重启 网络故障 模型 容器化 StarRocks 数据仓库 微软 SQL Server AI功能 Redka DBMS 管理系统 SpringAI JOIN 排行榜 排序 池化技术 连接池 MGR 分布式集群 原子性 Entity Caffeine CP 业务场景 事务隔离 网络 部署 LRU 分页方案 排版 Testcloud 云端自动化 数据字典 兼容性 Pottery dbt 数据转换工具 Valkey Valkey8.0 ReadView sqlmock 1 优化器 事务同步 悲观锁 乐观锁 关系数据库 意向锁 记录锁 日志 Weaviate 单线程 UUIDv7 主键 对象 单点故障 AIOPS 仪表盘 UUID ID InfluxDB Order 编程 Ansible Pump RAG HelixDB 双引擎 Crash 代码 分布式锁 Zookeeper 产业链 IT 恢复数据 订单 字典 LLM 线程安全 List 类型 国产 用户 慢SQL优化 表空间 拦截器 动态代理 解锁 调优 Next-Key RR 互联网 GitHub Git 快照读 当前读 视图 神经系统 矢量存储 数据库类型 AI代理 查询规划 count(*) count(主键) 行数 CAS 算法 技巧 多线程 并发控制 恢复机制 闪回