优雅地停止 docker 容器中的芹菜

Question

我在 docker 容器中运行 celery，处理来自rabbitmq 的任务。我试图停止并删除芹菜容器，同时允许当前正在运行的任务完成。文档建议向主进程发送 TERM 或 INT 信号应该热关闭 celery，尽管我发现子进程刚刚被杀死。

当我发送 TERM 正在运行的进程时，它会抛出：

WorkerLostError('Worker exited prematurely: signal 15 (SIGTERM).',)

当我发送 INT 时，正在运行的进程会退出，没有错误，尽管它也不允许任务按照文档的建议完成。

我使用以下命令启动 docker 容器： su -m celery_user -c "python manage.py celery worker -Q queue-name"

对于为什么会发生这种情况有什么想法吗？该信号是否会终止容器以及 celery 进程？

我用以下方式发送信号： docker kill --signal="TERM" containerid 或docker exec containerid kill -15 1

Answer 1

docker kill会杀死容器。您需要做的是将信号仅发送到主 celery 进程。

就我个人而言，我在 docker 容器内使用 Supervisord 来管理 celery Worker。默认情况下，supervisord 将发送消息SIGTERM来停止进程。

这是 celery 的主管配置示例

[program:celery]
command=celery worker -A my.proj.tasks --loglevel=DEBUG -Ofair --hostname celery.host.domain.com --queues=celery
environment=PYTHONPATH=/etc/foo/celeryconfig:/bar/Source,PATH=/foo/custom/bin:/usr/kerberos/bin
user=celery-user
autostart=true
stdout_logfile=/var/log/supervisor/celery.log
redirect_stderr=true