正文

如何轻松部署FastAPI应用，实现高效Celery作业队列管理

/0 浏览量
1015

在当今快速发展的互联网时代，高效的后端服务是保证应用性能的关键。FastAPI和Celery是两个强大的工具，FastAPI用于构建高性能的Web API，而Celery则用于异步任务队列管理。本文将带你轻松部署FastAPI应用，并实现高效Celery作业队列管理。

一、准备工作

在开始之前，请确保你的开发环境已经安装了以下依赖：

  • Python 3.6+
  • FastAPI
  • uvicorn（用于运行FastAPI应用）
  • Celery
  • Redis（作为消息代理）

你可以使用pip来安装这些依赖：

pip install fastapi uvicorn celery redis

二、创建FastAPI应用

首先，创建一个基本的FastAPI应用。以下是一个简单的例子：

from fastapi import FastAPI

app = FastAPI()

@app.get("/")
async def read_root():
    return {"message": "Hello World"}

保存这段代码为main.py。

三、配置Celery

接下来，配置Celery。首先，创建一个名为celery.py的文件，并添加以下内容：

from celery import Celery

app = Celery(
    'tasks', 
    broker='redis://localhost:6379/0', 
    backend='redis://localhost:6379/0'
)

app.conf.update(
    result_expires=3600,
)

这段代码配置了Celery使用Redis作为消息代理和结果存储。

四、创建异步任务

现在，创建一个异步任务。在main.py中添加以下内容：

from celery import Celery

app = FastAPI()
celery_app = Celery(app.name, broker=app.config['CELERY_BROKER_URL'])

@celery_app.task
def add(x, y):
    return x + y

这段代码定义了一个名为add的异步任务，它接受两个参数并返回它们的和。

五、运行FastAPI应用

使用以下命令运行FastAPI应用：

uvicorn main:app --reload

这将启动一个本地开发服务器，监听8000端口。

六、调用异步任务

现在，你可以通过FastAPI应用调用异步任务。在main.py中添加以下内容：

from celery.result import AsyncResult

@app.get("/add/{x}/{y}")
async def add(x: int, y: int):
    task = add.delay(x, y)
    return {"task_id": task.id}

这段代码定义了一个新的路由，它接受两个整数参数，并返回异步任务的ID。

七、监控任务状态

要监控任务状态，可以使用以下命令：

celery -A main.celery_app -B

这将启动Celery的监控工具，显示正在执行的任务和它们的当前状态。

八、总结

通过以上步骤，你已经成功部署了一个FastAPI应用，并实现了高效Celery作业队列管理。这样，你就可以轻松地处理大量并发请求，并确保你的后端服务保持高性能。

-- 展开阅读全文 --