我正试图在代码更改后重新启动celery,方法是遵循"如何在不延迟任务的情况下优雅地重新启动celery"。基于此,我运行:
(env1)ubuntu@ip-172-31-22-65:~/projects/tp$ ps aux|grep "celery"
ubuntu 2701 0.3 3.7 107788 37904 ? S 12:17 0:00 /home/ubuntu/.virtualenvs/env1/bin/python3.4 /home/ubuntu/.virtualenvs/env1/bin/celery --app=tp.celery:app worker --loglevel=INFO
ubuntu 2705 0.0 3.3 107120 34132 ? S 12:17 0:00 /home/ubuntu/.virtualenvs/env1/bin/python3.4 /home/ubuntu/.virtualenvs/env1/bin/celery --app=tp.celery:app worker --loglevel=INFO
ubuntu 2716 0.0 0.0 10460 932 pts/0 S+ 12:20 0:00 grep --color=auto celery
(env1)ubuntu@ip-172-31-22-65:~/projects/tp$ sudo kill -9 2701 2705
(env1)ubuntu@ip-172-31-22-65:~/projects/tp$ ps aux|grep "celery"
ubuntu 2720 16.3 3.7 107796 37908 ? S 12:25 0:00 /home/ubuntu/.virtualenvs/env1/bin/python3.4 /home/ubuntu/.virtualenvs/env1/bin/celery --app=tp.celery:app worker --loglevel=INFO
ubuntu 2724 0.0 3.3 107144 34084 ? S 12:25 0:00 /home/ubuntu/.virtualenvs/env1/bin/python3.4 /home/ubuntu/.virtualenvs/env1/bin/celery --app=tp.celery:app worker --loglevel=INFO
ubuntu 2726 0.0 0.0 10460 932 pts/0 S+ 12:25 0:00 grep --color=auto celery
我不明白这里发生了什么。在我杀死前两个之后,似乎出现了两个新的芹菜工人过程。
我做错了什么?
我没有看到任何证据表明你做错了什么。
芹菜是一个过程的集合。最重要的是一个主管,让一些员工随时准备回答请求。
工人是一次性的,但主管不能告诉工人在做什么。当工人离开时,主管收到一个信号并启动一个新的信号。就是这样。
如果您更改了配置,主管可以重新配置自己(如果您已经对其进行了配置!),但工作人员不会监视该配置。它们只有在出生时才会被配置。
你所做的"杀死"就是杀死那些工人,并期望替代工人在出生时拥有你想要的设置。
要求主管停止自己和工人,然后重新加载并重新开始,可能会留下几秒钟的时间,没有人回答任何请求。据我所知,这就是supervisorctl
的优势所在。
所以,你告诉我们的任何事情都没有明显的问题。你当然应该期待工人被替换。