celery在项目中的使用

Posted 2021-03-23 tangda

1 关于celery是一个处理异步耗时任务的框架 由 worker 和broker 和store 3部分组成

worker是来处理消息的工人

broker是来存储请求消息的仓库

store是用来存储结果的仓库

2 celery的使用

首先要有一个main文件

再者要有一个config文件

然后就是任务执行文件

如图 celery的目录

 

 

main.py 文件

 

 

config.py文件

 

 tasks.py文件

 

 最后

celery服务的开启命令

celery -A celery_tasks.email.tasks worker -l info 

注意：celery_tasks.email.tasks 是该函数执行的路径 填写正确才能启动celery服务