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("task", broker="redis://127.0.0.1:6379", backend="redis://127.0.0.1:6379") # 为应用创建任务,func1,2,3 @my_task.task def my_func1(a, b): time.sleep(20) return f"my_func1 return{a}{b}" @my_task.task def my_func2(): return "my_func2" @my_task.task def my_func3(): return "my_func3"