FastAPI非异步路由无法获取Request.body()？问题解析与解决

问题描述 #

在后端非异步路由中接收Ajax请求的Body参数时出现异常：异步路由可正常获取请求体，但非异步路由调用request.body()会抛出WouldBlock错误。

正常运行的异步路由代码 #

@app.post('/process-form')
async def process_form(request : Request):
    # Access form data
    form_data = await request.body()
    da = jsonable_encoder(form_data)
    print(da)

报错的非异步路由代码 #

@app.post('/process-form')
def process_form(request : Request):
    # Access form data
    form_data = request.body()
    da = jsonable_encoder(form_data)
    print(da)

报错信息 #

site-packages\anyio\streams\memory.py", line 89, in receive_nowait
    raise WouldBlock
anyio.WouldBlock

问题原因 #

• request.body()是异步方法，必须通过await关键字触发执行并获取结果。异步路由的协程上下文支持await操作，能等待异步任务完成；但同步路由没有异步上下文，直接调用只会返回未执行的协程对象，无法拿到实际请求体。
• 底层依赖的AnyIO库在同步环境下尝试无等待读取数据时，因数据未就绪抛出WouldBlock异常，提示当前操作无法立即完成。

非异步路由获取请求数据的解决方案 #

方案1：使用FastAPI官方同步兼容方式（推荐） #

FastAPI提供了Body依赖项，自动解析请求体并绑定到参数，无需处理异步逻辑：

from fastapi import Body

@app.post('/process-form')
def process_form(data: dict = Body(...)):
    print(data)
    return {"status": "success"}

如果有明确的请求体结构，还可以定义Pydantic模型来接收数据，更规范且自带校验：

from pydantic import BaseModel
from fastapi import Body

class FormData(BaseModel):
    username: str
    password: str

@app.post('/process-form')
def process_form(data: FormData = Body(...)):
    print(data.dict())
    return {"status": "success"}

方案2：手动在同步环境中运行异步方法 #

若必须直接操作request对象，可通过asyncio.run()执行异步的request.body()：

import asyncio
from fastapi import Request

@app.post('/process-form')
def process_form(request : Request):
    form_data = asyncio.run(request.body())
    da = jsonable_encoder(form_data)
    print(da)
    return {"status": "success"}

注意：多线程环境下可能出现事件循环冲突，仅在单线程场景下使用，优先选方案1。

方案3：转为异步路由 #

若业务逻辑允许，直接使用异步路由是最优解——FastAPI原生对异步支持友好，能更好处理IO密集型操作，避免同步异步切换的问题。

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