очередь шлет запрос и долго ждет ответ, то еть огромный таймаут и пок ответ не пришел, считает, что этот воркер занят.
А если я буду кидать в бекграунд работу и возвращать ответ 200, то из очереди нафлудиться в воркер один?
Хз, но очередь ничего не должна слать по своей сущности. В нее кидают, и из нее берут.
Если что-то типа такого и в amazon sqs from fastapi import BackgroundTasks, FastAPI app = FastAPI() async def train(): pass # very long @app.post("/train_model/") async def train_model(background_tasks: BackgroundTasks): background_tasks.add_task(train) return {"message": "Notification sent in the background"}
Обсуждают сегодня