安装celery

pip3 install celery

使用celery

创建celery_tasks 的包

  内部包括task.py文件

编写task.py文件

form celery import Celery

# 创建一个Celery实例对象，传入redis的ip端口和数据库
app = Celery('celery_tasks.tasks', broker='redis://127.0.0.1:6379/8'  

# 定义任务函数，使用task装饰器装饰
@ app.task  
def send_email(to_email, username, token):
      pass

导入celery.py

# 直接调用tasks.py内定义好的函数
send_email.delay(email, username, token)

-任务的发出者，中间人，任务的处理者可以在同一台电脑上启动，也可以不在同一台电脑上。
-处理者也需要知道运行的代码，需要将 django项目文件复制到所在的redis所在的电脑中

启动任务处理者前处理

# 在任务处理者，task.py文件中添加（django项目中无需添加，django会自动进行初始化）
import os
import django
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "项目名.setting")  # diango的wsgi.py文件夹下有现成代码，复制即可
django.setup()

启动任务处理者

# resdis所在计算机终端中运行
celery -A celery_tasks.tasks worker -l info