只是澄清的事情 – 我正在一个systemd服务文件celerybeat.service应该照顾芹菜节拍。 我现在正在做的是调用一个脚本,该脚本读取/var/run/celery/celerybeat.pid ,用该PID杀死进程,然后再次启动Celery节拍进程。
有没有更好的方法来完成这个?
我们所做的就是像这样启动芹菜(我们的芹菜应用在server.py中):
python -m server --app=server multi start workername -Q queuename -c 30 --pidfile=celery.pid --beat
其中30个工作进程启动一个芹菜节拍进程,并将该pid保存在celery.pid中。
然后我们可以调用它来干净地退出:
celery multi stop workername --pidfile=celery.pid