celery 学习

celery 的安装以及使用:

这里使用的消息中间件为rabbitmq


首先, 安装rabbitmq

拉取rabbitmq镜像:
docker pull rabbitmq


安装celery
pip install celery



使用celery的一些方法;
pass 今天不想写了



celery 启动关闭命令
1. celery multi start -A 启动文件名(无需带后缀名) worker -l info --logfile=日志文件名 --pidfile=pid文件名

2. 测试环境启动celery
celery -A celery_tasks.main worker -l info

3. 服务器启动celery
celery multi start -A celery_tasks.main worker -l info --logfile=celery.log --pidfile=celery.pid

4. 修改celery 之后 重新启动脚本
celery multi restart -A celery_tasks.main worker - l info --logfile=celery.log --pidfile=celery.pid

5. celery 全杀 (这里指的是服务器中的所有celery)
ps auxww | grep 'celery' | awk '{print $2}' | xargs kill -9

6. 清空指定队列消息 python manage.py celery purge -Q [queue_name]  清空指定队列消息



注意:
worker的启动
使用多进程模式启动: celery -A celery_server worker --loglevel=info # 这种方式启动worker服务后 worker会一直等待任务的执行 该方式默认的启动方式为多进程启动

使用单进程模式启动: celery -A celery_server worker --loglevel=info -P solo
 
使用协程模式启动: celery -A celery_server worker --loglevel=info -P eventlet   #注意这里需要安装 pip install eventlet