在FastAPI中使用Django 4.1异步ORM遇TypeError问题求助

问题根源 #

你遇到的TypeError: object QuerySet can't be used in 'await' expression错误，是因为直接对Django的同步QuerySet使用await。Django 4.1的异步ORM并非直接兼容同步的objects管理器，需要使用专门的异步API。

解决方案步骤 #

1. 替换为异步数据库引擎 #

Django的异步ORM要求数据库引擎支持异步操作，你当前使用的postgresql_psycopg2是同步引擎，需要修改配置并安装异步驱动：

• 修改数据库配置中的ENGINE：

DATABASES = {
    'default': {
        'ENGINE': 'django.db.backends.postgresql',  # 替换为异步PostgreSQL引擎
        'NAME': 'db',
        'USER': 'user',
        'PASSWORD': 'pass',
        'HOST': '127.0.0.1',
        'PORT': '5432',
    }
}

• 安装异步PostgreSQL驱动：

pip install psycopg[async]

2. 使用Django异步模型管理器aobjects #

Django为异步操作提供了aobjects管理器，通过它可以获取支持await的异步QuerySet，替代原有的同步objects。

3. 实现异步分页逻辑 #

Django内置的Paginator是同步实现，无法直接处理异步QuerySet，需要手动计算偏移量实现分页。

4. 异步处理序列化操作 #

serializers.serialize是同步IO操作，直接在异步函数中调用会阻塞事件循环，需用asyncio.to_thread将其包装到线程池执行。

完整修改后的FastAPI接口代码 #

import asyncio
import json
from django.core import serializers
from django.contrib.auth.models import User
from fastapi import APIRouter

router = APIRouter()

@router.get("/test-orm")
async def test_django_orm(page: int = 1, per_page: int = 2):
    # 构建异步查询条件
    queryset = User.aobjects.filter(username="user0")
    
    # 异步获取总条数
    total_count = await queryset.acount()
    
    # 计算分页偏移量
    offset = (page - 1) * per_page
    page_results = await queryset[offset:offset+per_page].afetch_all()
    
    # 异步执行序列化（避免阻塞事件循环）
    serialized_data = await asyncio.to_thread(
        serializers.serialize, 'json', page_results
    )
    paginated_data = json.loads(serialized_data)
    
    return {
        "data": paginated_data,
        "total": total_count,
        "page": page,
        "per_page": per_page
    }

关键说明 #

• aobjects：Django异步模型管理器，所有同步objects的方法都有对应的异步版本（如acount()替代count()，afetch_all()替代all()）
• 异步切片：异步QuerySet支持切片操作，需通过afetch_all()显式触发查询（或直接await切片后的QuerySet）
• asyncio.to_thread：将同步IO操作放到线程池执行，保证FastAPI的事件循环不被阻塞

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