检查python中正在运行的子进程的stdout

from subprocess import Popen,STDOUT
p = Popen(["tail","/tmp/file"],stderr=STDOUT)
for line in p.stdout:
    print(line)

我删除了shell = True和close_fds = True参数.第一个是不必要的,有潜在危险,而第二个是默认值.

请记住,文件对象可以在Python中通过它们的行进行迭代. for循环将一直运行,直到尾部死亡,但它将处理每条线,而不是读取,这将阻塞直到尾部死亡.

如果我在/ tmp / file中创建一个空文件,启动该程序并开始使用另一个shell将行回显到文件中,程序将回显这些行.您可能应该用更有用的东西替换print.

以下是我在启动上述代码后输入的命令示例：

命令行

$echo a > /tmp/file
$echo b > /tmp/file
$echo c >> /tmp/file

程序输出(来自不同shell中的Python)

b'an'
b'tail: /tmp/file: file truncatedn'
b'bn'
b'cn'

如果您希望主程序在响应tail的输出时响应,请在单独的线程中启动循环.您应该将此线程设置为守护程序,以便即使尾部未完成也不会阻止程序退出.您可以让线程打开子流程,也可以将标准输出传递给它.我更喜欢后一种方法,因为它可以让你在主线程中有更多的控制权：

def deal_with_stdout():
    for line in p.stdout:
        print(line)

from subprocess import Popen,STDOUT
from threading import Thread
p = Popen(["tail",stderr=STDOUT)
t = Thread(target=deal_with_stdout,daemon=True)
t.start()
t.join()

这里的代码几乎相同,添加了一个新线程.我在最后添加了一个join(),所以程序作为一个例子表现得很好(join在返回之前等待线程死掉).您可能希望用通常运行的任何处理代码替换它.

如果您的线程足够复杂,您可能还希望从Thread继承并覆盖run方法而不是传入一个简单的目标.