Celery的安装和简单使用（Redis作为消息中间件）
# 安装celery和redis依赖
# pip install celery redis
from celery import Celery
# 创建Celery实例，指定消息中间件为Redis
app = Celery('tasks', broker='redis://localhost:6379/0')
# 定义一个celery任务
@app.task
def add(x, y):
return x + y
# 使用Celery任务
# 在命令行启动celery worker:
# celery -A tasks worker --loglevel=info
# 在Python代码中调用异步任务
result = add.delay(4, 4)
print(f"等待结果: {result.id}")这段代码演示了如何安装和设置Celery以及如何定义和调用一个简单的异步任务。在实际应用中，你需要确保Redis服务器正在运行，并且根据你的环境可能需要修改broker的URL。
评论已关闭