标签:ret red RKE cal fun 函数 一个 基本使用 使用
创建一个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 所在目录下运行:
[root@localhost ~]# celery -A tasks worker --loglevel=info # 启动方法1 [root@localhost ~]# celery -A tasks worker --l debug # 启动方法2
标签:ret red RKE cal fun 函数 一个 基本使用 使用
原文地址:https://www.cnblogs.com/liuhaidon/p/12036498.html