如何在fastapi中使用asyncio.semapahore？

Question

我正在为图像分类模型构建FastAPI服务器。 API接收图像URL并使用HTTPX同时下载它们。我想使用asyncio.semaphores限制服务器上的并发下载次数。我尝试在所有请求中共享一个分类器属性作为分类器属性。但是我会收到错误：获得了未来的未来待处理，从/usr/lib/python3.9/asyncio/base/base_events.py:424>附加到其他循环。

这是我的代码：

 
# classifier.py

import asyncio
import httpx


class Classifier():
    def __init__(
        self,
        concurrency_limit,
    ) -> None:
        self.client = httpx.AsyncClient()
        self.semaphore = asyncio.Semaphore(concurrency_limit)

    async def download_async(self, url):
        async with self.semaphore:
            response = await self.client.get(url)

        return await response.aread()

    async def run(
        self, image_urls
    ):
        image_list = await asyncio.gather(
            *[self.download_async(url) for i, url in enumerate(image_urls)]
        )

        # Infer Images
        pass



# api.py
from fastapi import FastAPI

server = FastAPI()

classifier = Classifier(concurrency_limit=5)

@server.post("/")
async def index(urls):
    results = await classifier.run(urls)

在线上提及在运行事件循环中创建信号的答案，但是如果我在run（）中创建它，为每个请求创建一个新的信号量。即，每个请求允许同时下载5个。如何在所有请求中使用相同的信号量？