FastAPI 中间件如何同步执行?

fastapi 中间件如何同步执行?

fastapi中将中间件改为同步模式

在fastapi中,中间件通常是异步的,但这会带来一些 inconveniente,尤其是在使用不兼容异步的库时。因此,对于希望将中间件函数保持为同步的情况,可以考虑以下解决方案:

使用run_in_threadpool执行同步代码

run_in_threadpool是一个辅助函数,允许在后台线程池中运行同步代码。我们可以使用它来将同步代码包装在异步函数中,如下所示:

from fastapi import FastAPI, Request, Response
from starlette.concurrency import run_in_threadpool

app = FastAPI()

def sync_code():
    # 这里放你的同步代码
    pass

@app.middleware("http")
async def sync_middleware(request: Request, call_next):
    await run_in_threadpool(sync_code)
    response = await call_next(request)
    return response

在这种方法中,sync_code函数包含你的同步代码。run_in_threadpool将其包装在一个异步函数中,允许它在后台线程池中运行。这样,你就可以在中间件中使用同步代码,同时保持其异步性质。

以上就是FastAPI 中间件如何同步执行?的详细内容,更多请关注硕下网其它相关文章!