celery 注意的事项

命令执行注意事项

• 如果设置任务的存储引擎为redis，或其他的数据库，不是rabbitmq
  则执行命令的时候必须加项目

celery -A proj status

否则会报错默认还会使用rabbitmq 连接

image.png

• 如果遇到如下错误的话

image.png

在django 中 可以在setting 使用
from celery import  platforms
platforms.C_FORCE_ROOT = True

第二种也可以使用    

    
export C_FORCE_ROOT="true"

celery 启用外部配置文件

>>> celery.config_from_object("myapp.celeryconfig")

>>> from myapp import celeryconfig
>>> celery.config_from_object(celeryconfig)

关于 multi 命令

multi 命令可以在后台启动多个节点也可以重启，暂停

启动

$ celery multi start w1 -A proj -l info
celery multi v3.1.1 (Cipater)
> Starting nodes...
    > w1.halcyon.local: OK


重启

$ celery multi restart w1 -A proj -l info
celery multi v3.1.1 (Cipater)
> Stopping nodes...
    > w1.halcyon.local: TERM -> 64024
> Waiting for 1 node.....
    > w1.halcyon.local: OK
> Restarting node w1.halcyon.local: OK
celery multi v3.1.1 (Cipater)
> Stopping nodes...
    > w1.halcyon.local: TERM -> 64052


暂停

celery multi stop w1 -A proj -l info

image.png