Celery 异步定时周期任务

1/什么是Celery

Celery 是基于Python实现的模块,用于执行异步定时周期任务的

其结构的组成是由

　　1.用户任务app

　　2.管道 broker 用于存储任务 官方推荐 redis rabbitMQ / backend 用于存储任务执行结果的

　　3.员工 worker

2.Celery的简单实例

from celery import Celery

import time

# 创建一个Celery实例，这就是我们用户的应用app

my_task = Celery("tasks", broker="redis://127.0.0.1:6379",backend="redis://127.0.0.1:6379")

# 为应用创建任务,func1

@my_task.task

def func1(x, y):

    time.sleep(15)

    return x + y

s1.py

from s1 import func1

# 将任务交给Celery的Worker执行

res = func1.delay(2,4)

# 返回任务ID

print(res.id)

s2.py

from celery.result import AsyncResult

from s1 import my_task

# 异步获取任务返回值

async_task = AstyncResult(id="31ec65e8-3995-4ee1-b3a8-1528400afd5a",app=my_task)

# 判断异步任务是否执行成功

if async_task.successful():

    #获取异步任务的返回值

    result = async_task.get()

    print(result)

else:

    print("任务还未执行完成")

s3.py

根据操作系统的不同,启动方式也存在差异:
Linux - celery worker -A s1 -l INFO
Windows:这里需要注意的是celery 4.0 已经不再对Windows操作系统提供支持了,也就是在windows环境下出现问题除非自己解决,否贼官方是不会给你解决的
Windows - celery worker -A s1 -l INFO -P eventlet
ps: eventlet 是一个python的三方库 需要使用 pip安装 pip install eventlet