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"
s1

相关文章: