Celery version 4.0 runs on
Python ?2.7, 3.4, 3.5?
PyPy ?5.4, 5.5?
This is the last version to support Python 2.7, and from the next version (Celery 5.x) Python 3.5 or newer is required.

If you’re running an older version of Python, you need to be running an older version of Celery:

Python 2.6: Celery series 3.1 or earlier.
Python 2.5: Celery series 3.0 or earlier.
Python 2.4 was Celery series 2.2 or earlier.

Celery is a project with minimal funding, so we don’t support Microsoft Windows. Please don’t open any issues related to that platform.

pip install celery

app=Celery(‘任务名‘，backend=‘xxx‘,broker=‘xxx‘)

# celery_task.py

from celery import Celery
# 不加密码
broker=‘redis://127.0.0.1:6379/0‘   # borker配置，任务队列
backend=‘redis://127.0.0.1:6379/1‘  # backend配置 执行结果存储

#加密码
# backend=‘redis://:123456@127.0.0.1:6379/1‘
# broker=‘redis://:123456@127.0.0.1:6379/2‘
#一定要指定一个名字


app=Celery(‘test‘,broker=broker,backend=backend)  # 创建任务异步处理器


#任务其实就是个函数
#需要用一个装饰器 *.task装饰,表示该任务是被 * celery管理的，并且可以用celery执行的
@app.task
def add(x,y):
    import time
    time.sleep(2)  # 模拟阻塞任务
    return x+y

#用于提交任务的py文件

import celery_task

#提交任务到消息队列中
#只是把任务提交到消息队列中，并没有执行需要启动worker才可以生效
ret=celery_task.add.delay(3,4)  # add 即celery_task中add函数
print(ret)
# ret=a5ea035f-0cc3-44ba-b334-f5d7c7ce681d  :任务的id号，待任务执行完毕，需要通过这个id去backend去取执行结果



#提交定时任务：于2019-07-20 11:13:56执行的任务，此任务只是在这里提交了，需要启动worker才可以生效
from datetime import datetime
v1 = datetime(2019, 7, 20, 11, 13, 56)
print(v1)  # 时间对象
v2 = datetime.utcfromtimestamp(v1.timestamp())
print(v2)  

# #取出要执行任务的时间对象，调用apply_async方法，args是参数，eta是执行的时间
result = celery_task.add.apply_async(args=[1, 3], eta=v2)
print(result.id)   # 任务的id号，待任务执行完毕，需要通过这个id去backend去取执行结果

#第二种获取时间的方法
ctime = datetime.now()
# 默认用utc时间
utc_ctime = datetime.utcfromtimestamp(ctime.timestamp())
from datetime import timedelta
#取10s之后的时间对象
time_delay = timedelta(seconds=3)
task_time = utc_ctime + time_delay   # 时间对象的相加
result = celery_task.add.apply_async(args=[4, 3], eta=task_time)
print(result.id)

# 方法一：
from celery_task import app
if __name__ == ‘__main__‘:
    app.worker_main()
    # cel.worker_main(argv=[‘--loglevel=info‘)

# 方法二：
# 命令行启动—常用
# linux下： celery worker -A celery_task_s1 -l info
# windows下：celery worker -A celery_task_s1 -l info -P eventlet  #eventlet是个模块 需要pip装下

# 创建py文件：result.py，查看任务执行结果

from celery.result import AsyncResult
from celery_task import app

async = AsyncResult(id="e919d97d-2938-4d0f-9265-fd8237dc2aa3", app=cel)

if async.successful():
    result = async.get()
    print(result)
    # result.forget() # 将结果删除
elif async.failed():
    print(‘执行失败‘)
elif async.status == ‘PENDING‘:
    print(‘任务等待中被执行‘)
elif async.status == ‘RETRY‘:
    print(‘任务异常后正在重试‘)
elif async.status == ‘STARTED‘:
    print(‘任务已经开始被执行‘)