fastapi 在中间件中获取requestBody

在FastAPI中，在中间件中直接获取请求体（request body）是不可能的，因为在ASGI应用调用过程中，请求体是一个流，只能被读取一次。如果你需要在中间件中访问请求体数据，你可以在中间件中修改请求对象，将请求体数据缓存起来。

以下是一个示例代码，展示了如何在FastAPI中创建一个中间件来缓存请求体数据：

from fastapi import FastAPI, Request
from starlette.middleware.base import BaseHTTPMiddleware
from starlette.requests import Request
from starlette.responses import JSONResponse
 
app = FastAPI()
 
class CacheBodyMiddleware(BaseHTTPMiddleware):
    async def dispatch(self, request: Request, call_next):
        # 将请求体缓存到属性中
        body = await request.body()
        request.state.body = body
        
        response = await call_next(request)
        return response
 
@app.middleware("http")
async def add_middleware(request: Request, call_next):
    return await CacheBodyMiddleware.dispatch(request, call_next)
 
@app.post("/items/")
async def create_item(request: Request, item: dict):
    # 使用中间件缓存的请求体数据
    cached_body = request.state.body
    return JSONResponse({"body": cached_body, "item": item})

在这个示例中，CacheBodyMiddleware 中间件将请求体数据缓存到了 request.state.body 中。request.state 是一个特殊的属性，FastAPI用来在请求处理的多个阶段共享数据。然后，在路由处理函数中，你可以通过 request.state.body 访问这个缓存的请求体数据。

请注意，这种方法只适合非流式的请求体数据，如果你需要处理大型文件上传，这种方法可能会导致内存消耗和性能问题。在实际应用中，你应该小心使用这种技巧，并确保它不会破坏应用的其他部分，如数据流的处理。