[Python] FastAPI踩坑记录--中间件消费请求体后请求卡死的分析和解决

@app.middleware("http")
async def sync_middleware(request: Request, call_next):
    request_json = await request.json()
    _data = {
        "ip":request.client.host,
        "X-Sign":request.headers.get("X-Sign"),
        "body":request_json,
    }
    # 同步代码，做鉴权
    result = await run_in_threadpool(sync_code, _data)
    if result != 200:
        return Response(status_code=result)
    
    response = await call_next(request)
    return response

from fastapi import FastAPI, Request, Response, APIRouter
from typing import Callable
from fastapi.routing import APIRoute
from pydantic import BaseModel

class middlewareRoute(APIRoute):
    def get_route_handler(self) -> Callable:
        original_route_handler = super().get_route_handler()

        async def custom_route_handler(request: Request) -> Response:
            before = time.time()
            
            # 这里可以获取的我们的请求的体的信息----
            
            response: Response = await original_route_handler(request)

            request_body = await request.body()

            _data = {
                "ip":request.client.host,
                "X-Sign":request.headers.get("X-Sign"),
                "body":request_body,
            }

            # 同步代码，做鉴权
            result = await run_in_threadpool(sync_code, _data)
            if result != 200:
                return Response(status_code=result)
            
            # 下面可以处理我们的响应体的报文信息
            
            duration = time.time() - before
            response.headers["X-Response-Time"] = str(duration)
            # print(f"route duration: {duration}")
            # print(f"route response: {response}")
            # print(f"route response headers: {response.headers}")
            return response

        return custom_route_handler
        
app = FastAPI()
router = APIRouter(route_class=middlewareRoute)

@app.get("/")
def index():
    return {}

class SignData(BaseModel):
    Zzz: str
    Abc: str
    Def: str

@router.post("/func")
def func_test(signData:SignData):
    # 省略功能代码
    return {}

app.include_router(router)