使用 subprocess.PIPE 进行增量输出

Question

我正在使用 subprocess 模块从另一个应用程序运行命令我知道您可以执行以下操作

import subprocess

app = subprocess(args, stdout=subprocess.PIPE)
out, err = app.communicate()
print out

我希望输出显示为最后发生的一个大斑点。有想法吗？

Answer 1

问题可能是您在子进程中运行的命令缓冲了其输出：在这种情况下，在 Blender 的回答中，process.stdout.read(1) 直到子进程的输出缓冲区才会返回。子进程已满，导致其被刷新，从而被父进程看到。

请参阅此答案和这个 了解有关缓冲如何影响事物的更多信息。

下面是一些脚本来说明：

# spew.py
import sys
import time

for i in range(10):
    print 'Message no. %d' % i
    #sys.stdout.flush()
    time.sleep(1)

现在

# runspew.py
import subprocess
import time

start = time.time()
p = subprocess.Popen(['python', 'spew.py'], stdout=subprocess.PIPE)
data = p.stdout.read(1)
print 'Elapsed time to first byte read: %.2f' % (time.time() - start)
data = p.stdout.read()
print 'Elapsed time to last byte read: %.2f' % (time.time() - start)
p.wait()

，将两个脚本放在同一目录中并运行 python runspew.py。您会看到类似这样的内容：

Elapsed time to first byte read: 10.05
Elapsed time to last byte read: 10.05

现在，从 spew.py 中的 sys.stdout.flush() 中删除注释并执行 python runspew.py 再次。现在，您将看到类似这样的内容：

Elapsed time to first byte read: 0.02
Elapsed time to last byte read: 10.04

请注意，runspew.py 没有更改：仅更改了作为子进程运行的程序。如果您正在运行的程序无法以无缓冲方式运行（或频繁刷新），那么您必须使用 expect/unbuffer ，如另一个中所述我链接到的答案。

Answer 2

我曾经做过一个 Python shell 实现，所以这是我用来运行命令的代码。它运行wget和nano很好，所以我认为代码会满足您的需求：

  process = subprocess.Popen(shlex.split(command), stdout = subprocess.PIPE, stderr = subprocess.STDOUT)

  while True:
    output = process.stdout.read(1)

    if output == '' and process.poll() != None:
      break

    if output != '':
      sys.stdout.write(output)
      sys.stdout.flush()

基本上，您必须直接写入stdout。