芹菜.减少进程数量

Question

有没有办法限制芹菜的工人数量？我有小型服务器,芹菜总是在1个核心处理器上创建10个进程.我想将这个数字限制为3个进程.

Answer 1

我尝试在settings.py文件中将并发设置为1,将max_tasks_per_child设置为1,并同时运行3个任务.它只是作为用户产生1个过程而另外2个产生芹菜.它应该只运行1个进程,然后等待它完成,然后再运行另一个进程.

我正在使用django芹菜.

编辑 {

我通过在settings.py文件中编写CELERYD_CONCURRENCY = 1来分配并发性.但是当我使用"tail -f /var/log/celery/w1.log"查看celery日志文件时,我看到了8分配给并发的值.这告诉我,setting.py不会改变并发性.为了解决这个问题,我在"/ etc/default/celeryd"文件中添加了以下行.

# Extra arguments to celeryd
CELERYD_OPTS="--concurrency=1"

现在队列中的第二个任务一直等到第一个完成.

}

Answer 2

celery worker --concurrency选项允许指定处理队列的子进程数.