3

我有一个设计用来运行任务的大型脚本,一次一个。但是我有一个初始化脚本,它使用 start-stop-daemon 在我们想要的任何时候终止脚本。脚本结束得很好,但是 subprocess 命令运行直到它完成。我怀疑这可能只是我如何尝试执行全局变量的问题。或者我使用 .communicate 与子进程。无论如何,这是代码中的相关内容:

import subprocess
import os
import signal

pro = ''

def sigHandler( signum, frame ):
    global pro
    os.killpg( pro.pid, signal.SIGTERM )
    sys.exit()

def run(data):
    #I found an example using preexec_fn somewhere on stackoverflow. Cant
    #remember if they were using .communicate() or not
    global pro
    pro = subprocess.Popen( command, stdout = subprocess.PIPE, stderr = subprocess.PIPE, shell = False, preexec_fn = os.setsid ).communicate()
    return( 1 )

if __name__ == '__main__':
    signal.signal( signal.SIGTERM, sigHandler )
    while True:
        run( relevantData )
4

1 回答 1

0

朋友帮我弄明白了。正如我在评论中所说,当命令运行时 pro 没有被填充。所以我不得不将我的代码更改为:

pro = subprocess.Popen( command, stdout = subprocess.PIPE, stderr = subprocess.PIPE, shell = False, preexec_fn = os.setsid )
pro.communicate()

然后它起作用了:)

于 2012-12-04T20:07:25.443 回答