如何在 fastapi 中将中间件改成同步模式？

在 fastapi 中，中间件函数通常被声明为异步函数，以便在不同的请求之间进行并行处理。但是，如果你ต้องการ在中间件中使用不支持异步的同步库，则可以采用以下方法将中间件改成同步模式：

1. 使用 run_in_threadpool:

   此函数允许你在线程池中执行同步代码。你可以将其包裹在中间件函数中，如下所示：

   from fastapi import fastapi, request, response from starlette.concurrency import run_in_threadpool  app = fastapi()  def sync_code():     # 这里放你的同步代码  @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 函数将该函数包装在一个线程中执行，以保持中间件的异步性质。

2. 手动等待结果:

   另一种方法是手动等待中间件函数中执行的同步代码的结果。这可以通过将 async 关键字从中间件函数中删除，并使用 await 来等待同步代码执行后的结果来实现。

   from fastapi import FastAPI, Request, Response  app = FastAPI()  def sync_code():     # 这里放你的同步代码  @app.middleware("http") def sync_middleware(request: Request, call_next):     sync_code()     response = call_next(request)     return response

   请注意，这种方法可能导致性能问题，因为中间件将阻塞，直到同步代码执行完成。

通过使用这些方法，你可以将 fastapi 中的中间件改成同步模式，以便在需要使用同步库时解决兼容性问题。