celery 踩坑  启动命令

celery 启动

 

一定要切换目录到django  项目    然后启动celery文件 

比如 cd  项目目录

celery  -A   celery文件路径  worker  -l  info   &  
celery -A tasks.Wish_celery worker -l info    &
 
 
celery -A picha beat -l info
登录到Django后台,可以看到后台数据库中看到有任务的参数,效果图暂略。

然后启动终端,切换到Django项目的根目录下,运行:

celery worker -A 项目名 -l info  
这条命令用于启动worker, worker本质上执行任务的线程,就是一个干苦力的工人。

celery beat -A 项目名 -l info
上面这条任务用于启动beater,它就像一个领导,负责把任务分发给工人。
 

上一篇:[源码解析] 并行分布式框架 Celery 之架构 (2)


下一篇:[源码解析] 并行分布式任务队列 Celery 之 消费动态流程