1

我有这个我的项目文件夹结构

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 检查命令的输出

$ 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.

我不确定为什么它不起作用

4

1 回答 1

3

您可以尝试运行为：

/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 celeryResult 将是这样的：

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
于 2013-07-05T19:51:07.660 回答