fastapi celery

FastAPI 和 Celery 都是 Python 语言中常用的 Web 应用框架和异步任务队列框架。它们可以很好地结合使用，实现高性能的 Web 应用和异步任务处理。下面是一个简单的 FastAPI 和 Celery 结合的示例。

首先，我们需要安装 FastAPI 和 Celery，可以使用 pip 命令进行安装：

pip install fastapi celery

接下来，我们需要创建一个 FastAPI 应用程序，并将 Celery 配置为其异步任务队列。为此，我们可以创建一个名为 `main.py` 的文件，添加以下代码：

from fastapi import FastAPI
from celery import Celery

app = FastAPI()

# Celery 配置
celery = Celery('tasks', broker='pyamqp://guest@localhost//')

# 异步任务
@celery.task
def add(x, y):
    return x + y

# FastAPI 路由
@app.get('/')
async def root():
    result = add.delay(4, 4)
    return {'result': result.id}

在上面的代码中，我们首先创建了一个名为 `app` 的 FastAPI 应用程序，然后使用 Celery 创建了一个名为 `celery` 的异步任务队列。接下来，我们定义了一个名为 `add` 的异步任务，该任务接受两个参数 `x` 和 `y`，并返回它们的和。最后，我们创建了一个 FastAPI 路由，该路由调用了 `add` 异步任务，并返回任务 ID。

现在，我们可以使用以下命令启动 Celery worker 和 FastAPI 应用程序：

celery -A main.celery worker --loglevel=info
uvicorn main:app --reload

这将启动 Celery worker 和 FastAPI 应用程序，并在访问 `http://localhost:8000/` 时调用异步任务，并返回任务 ID。

总之，FastAPI 和 Celery 可以很好地结合使用，实现高性能的 Web 应用和异步任务处理。通过使用异步任务队列，可以将耗时的任务转移到后台处理，从而提高 Web 应用程序的响应速度和性能。