Celery停止了任务却未关闭子进程，怎么破？
Page content
这问题似乎挺棘手的，毕竟我所进行的任务是通过celery下发给subprocess的。在查阅了资料我有了解决办法，以下是简化后的代码便于理解
🍺本篇文章大约需要1分钟来阅读，届时你或许将学到：
- 杀死子进程
首先，我们获取该进程的PID，这很重要。
def run_code(code):
return Popen(code,shell=True).pid
然后我们通过类似如下命令（可能写得比较烂）找出所有子进程的PID，例如父进程PID为66687
ps -ef|grep 66687|awk '{print $2,$3}'|grep ' 66687'|awk '{print $1}'
于是我们编辑代码退出方法如下。
def kill_proc(pid):
Popen(f"kill -9 `ps -ef|grep {pid}|awk"+ " '{print $2,$3}'|grep ' "+f"{pid}'|awk '"+"{print $1}'`",shell=True).wait()
希望这能帮到你，如有疑问请联系我。
