Python—Celery 框架使用

二、Celery基本使用 

创建一个celery application 用来定义你的任务列表，创建一个任务文件就叫tasks.py吧

from celery import Celery

# 配置好celery的backend和broker
app = Celery(‘task1‘,  backend=‘redis://127.0.0.1:6379/0‘, broker=‘redis://127.0.0.1:6379/0‘)

#普通函数装饰为 celery task
@app.task
def func(x, y):
    return x + y

启动Celery Worker来开始监听并执行任务。broker 我们有了，backend 我们有了，task 我们也有了，现在就该运行 worker 进行工作了，在 tasks.py 所在目录下运行：

[[email protected] ~]# celery -A tasks worker --loglevel=info    # 启动方法1
[[email protected] ~]# celery -A tasks worker --l debug            # 启动方法2

原文地址：https://www.cnblogs.com/liuhaidon/p/12036498.html