芹菜多不按预期工作

Question

我有我的项目文件夹结构

api
    -- __init__.py
    --jobs/
        -- __init__.py
        -- celery.py
        -- celeyconfig.py
        -- tasks.py
    --api_helpers/
    --views/

tasks有一个名为ExamineColumns 的任务

我使用celery worker -A api.jobs --loglevel=Info 启动工作程序

它运行良好，我可以运行任务。

这是我们的芹菜检查命令

$ celery inspect registered
-> ranjith-ThinkPad-T420: OK
    * ExamineColumns
    * celery.backend_cleanup
    * celery.chain
    * celery.chord
    * celery.chord_unlock
    * celery.chunks
    * celery.group
    * celery.map
    * celery.starmap

但当我尝试多模式时，它根本不起作用。我正试图通过运行来运行

celery multi start w1 -c3 -A api.jobs  --loglevel=Info

但它根本没有开始。

$ celery inspect registered
Error: No nodes replied within time constraint.

我不确定它为什么不工作

Answer 1

您可以尝试运行为：

/usr/bin/celery multi start w1 w2 --uid=www --loglevel=INFO --pidfile=/var/run/%n.pid --logfile=/var/log/%n.log --quiet

--uid必须是来自服务器的用户/组。不建议使用root

--quiet不会向控制台输出数据

%n.log将在w1.log和w2.log 上替换自己

---

对于检查，您可以使用ps uax | grep celery结果如下：

www ... /usr/local/bin/python2.7 -m celery.bin.celeryd -n w1.domain.ru --loglevel=DEBUG --logfile=/var/log/w1.log --pidfile=/var/run/w1.pid
www ... /usr/local/bin/python2.7 -m celery.bin.celeryd -n w2.domain.ru --loglevel=DEBUG --logfile=/var/log/w2.log --pidfile=/var/run/w2.pid