fastapi中的后台任务发出阻塞请求

Question

我有一个资源密集型异步方法，我想将它作为后台任务运行。它的示例代码如下所示：

@staticmethod
async def trigger_task(id: str, run_e2e: bool = False):
    try:
        add_status_for_task(id)
        result1, result2 = await task(id)
        update_status_for_task(id, result1, result2)
    except Exception:
        update_status_for_task(id, 'FAIL')


@router.post("/task")
async def trigger_task(background_tasks: BackgroundTasks):
    background_tasks.add_task(EventsTrigger.trigger_task)
    return {'msg': 'Task submitted!'}

当我触发这个端点时，我期望一个即时输出：{'msg': 'Task submitted!'}。而是等待 api 输出，直到任务完成。我正在关注来自fastapi 的文档。

fastapi: v0.70.0 蟒蛇：v3.8.10

我相信这个问题类似于here 所描述的问题。 请求帮助以使其成为非阻塞调用。

Answer 1

我从 github 问题中学到了什么，

• 您不能将async def 用于任务功能（它将在后台运行。）
• 由于在后台进程中您无法访问协程，因此您的 async/await 将无法正常工作。
• 您仍然可以尝试不使用 async/await。如果这也不起作用，那么您应该选择其他方法。

替代背景解决方案

• Celery 是生产就绪的任务调度程序。因此，您可以使用your_task_function.delay(*args, **kwargs) 轻松配置和运行后台任务
• 请注意， Celery 也不支持后台任务中的异步。因此，您需要编写的只是同步代码以在后台运行。

祝你好运:)

Answer 2

你的应用程序是如何运行的？

根据 uvicorn 文档，它默认运行 1 个 worker，这意味着只会同时发出一个进程。 尝试配置您的 uvicorn 以与更多工作人员一起运行。 https://www.uvicorn.org/deployment/

$ uvicorn example:app --port 5000 --workers THE_AMOUNT_OF_WORKERS
or
uvicorn.run("example:app", host="127.0.0.1", port=5000, workers=THE_AMOUNT_OF_WORKERS)