1、新建tasks.py文件，在该文件内定义我们的功能函数，比如add

from celery import Celery

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

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

2、启动redis作为消息中间件，使用内置的rpc作为结果存储地

3、启动celery

/usr/local/python365/bin/celery -A tasks worker --loglevel=info

4、在tasks.py所在目录下，新建其他文件，比如test.py，在test.py中引入tasks.py中add函数

5、运行test.py，即可实现add的调用

 

常用使用方法

result.get()        # 获取任务的返回值

result = add.delay(4,4)        # 调用任务函数

result.ready()        # 查看任务执行进度或结果 False 未完 True 结束

result.id        # 任务ID