Existe uma maneira mais conveniente de interromper (ou reiniciar) um processo de batida de aipo desanexado?

Question

Só para esclarecer as coisas - estou trabalhando em um arquivo de serviço systemd celerybeat.service que deve cuidar da batida do Aipo. O que estou fazendo no momento é chamar um script que lê /var/run/celery/celerybeat.pid , mata o processo com esse PID e, em seguida, inicia o processo de batida de aipo novamente.

Existe uma maneira melhor de conseguir isso?

    

Answer 1

O que fazemos é começar o aipo assim (nosso aplicativo de aipo está no server.py):

python -m server --app=server multi start workername -Q queuename -c 30 --pidfile=celery.pid --beat

Que inicia um processo de batida de aipo com 30 processos de trabalho e salva o pid em celery.pid.

Então podemos chamar isso para sair de forma limpa:

celery multi stop workername --pidfile=celery.pid