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) 不会返回，直到子进程的输出缓冲区填满，导致它被刷新，因此被父进程看到。

有关缓冲如何影响事物的更多信息，请参阅 this answer 和 this one。

这里有一些脚本来说明：

# 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

现在，从sys.stdout.flush() 中删除spew.py 中的评论，然后再次执行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。