一、celery的作用

celery 是一个简单、灵活且可靠的分布式系统，用于处理大量消息，同时为操作提供一致的接口。它专注于实时操作，但支持任务调度。

Celery 主要用于异步任务处理，特别是在Web应用环境中，用于执行后台任务，如发送电子邮件、处理图片、视频转码、运行复杂的计算等，而不必阻塞Web请求/响应周期。

二、安装celery

命令：

三、使用celery 异步执行任务

官方文档：First steps with Django — Celery 5.4.0 documentation (celeryq.dev)

1、配置

• 1）给celery设置环境，为django项目的环境
• 2）创建celery实例
• 3）设置broker,也就是我们存放任务的队列,这里从配置文件中加载broker
• 4）设置自动检测任务，autodiscover_tasks方法

具体实现如下:

broker配置文件如下，这里用redis做队列来存任务：

2、创建好celery实例和配置broker之后，开始创建任务

比如我要创建一个发送邮件的任务：

• 1）创建文件夹，创建tasks.py文件

• 2）在tasks.py文件中编写任务(函数)， 一定要用task装饰器修饰起来

• 3）在app.autodiscover_tasks([ ])中添加你的任务

参数是列表，列表中的元素是task的路径(就是要执行的任务所在的路径)

• 4）在你想要异步执行该函数的地方导入，用delay方法将任务推到队列中

四、使用celery定期执行任务

官方文档：Periodic Tasks — Celery 5.4.0 documentation (celeryq.dev)

1、创建一个文件，专门用来放定时任务的配置(也可以不用)

• task： 就是要执行的定时任务， 注意位置要找对，要找到对应的函数
• schedule：执行的周期

2、用 app.conf.beat_schedule 来指定我们的定时任务

3、在app.autodiscover_tasks([ ])中添加你的任务

参数是列表，列表中的元素是task的路径(就是要执行的任务所在的路径)

五、启动命令

• 命令：Celery -A celery实例脚本文件 worker --loglevel=INFO
• linux命令：celery -A celery_tasks.main worker --loglevel=INFO
• windows命令：celery -A celery_tasks.main worker --concurrency=4 --loglevel=INFO -P threads

定时任务，需要开两个终端分别执行两条命令，celery_tasks.main替换成你自己的脚本文件

• 1、celery -A celery_tasks.main worker --concurrency=4- -loglevel=INFO -P threads
• 2、celery -A celery_tasks.main beat --loglevel=INFO

六、 效果展示

任务的执行

定期任务的执行

七、具体文件目录

• main.py

• config.py

• celery_beat_schedule.py