异步之舞：Motor驱动与MongoDB的CRUD交响曲

title: 异步之舞：Motor驱动与MongoDB的CRUD交响曲
date: 2025/05/19 15:30:10
updated: 2025/05/19 15:30:10
author: cmdragon

excerpt:
Motor 异步驱动是专为 Python 异步框架设计的 MongoDB 连接器，基于 asyncio 实现非阻塞 I/O 操作，提升 FastAPI 的并发处理能力。通过 CRUD 操作示例，展示了如何使用 insert_one、find、update_one 和 delete 方法进行文档的创建、查询、更新和删除。聚合管道用于统计用户年龄分布，索引优化策略包括单字段索引和复合索引，遵循 ESR 规则提升查询性能。常见报错如 ServerSelectionTimeoutError、ValidationError 和 DuplicateKeyError 的处理方法也进行了详细说明。

categories:

• 后端开发
• FastAPI

tags:

• Motor
• 异步驱动
• CRUD操作
• MongoDB
• FastAPI
• 索引优化
• 聚合管道

扫描二维码)
关注或者微信搜一搜：编程智域 前端至全栈交流与成长

探索数千个预构建的 AI 应用，开启你的下一个伟大创意：https://tools.cmdragon.cn/

第二章：Motor 异步驱动与 CRUD 操作实践

1. Motor 异步驱动原理

MongoDB 的异步驱动 Motor 是专为 Python 异步框架设计的数据库连接器，其底层基于 asyncio 实现非阻塞 I/O 操作。与同步驱动相比，Motor
在执行数据库操作时不会阻塞事件循环，这使得 FastAPI 能够同时处理更多并发请求。

示例场景：想象餐厅里一个服务员（事件循环）同时服务多桌客人（请求），当某桌需要等待厨房做菜（数据库操作）时，服务员会先去服务其他餐桌，等厨房完成后再回来继续服务。

# 安装依赖
# pip install fastapi==0.78.0 motor==2.5.0 pydantic==1.10.7

from fastapi import FastAPI
from motor.motor_asyncio import AsyncIOMotorClient
from pydantic import BaseModel

app = FastAPI()

# MongoDB 连接配置
DATABASE_URL = "mongodb://localhost:27017"
client = AsyncIOMotorClient(DATABASE_URL)
db = client["mydatabase"]
users_collection = db["users"]


class UserCreate(BaseModel):
    name: str
    age: int
    email: str


class UserResponse(UserCreate):
    id: str

2. CRUD 操作实现

2.1 创建文档

使用 insert_one 方法实现数据插入：

@app.post("/users", response_model=UserResponse)
async def create_user(user: UserCreate):
    user_dict = user.dict()
    result = await users_collection.insert_one(