Python - 写入标准输入的子进程，以便主程序可以从标准输入读取它

Question

我有一个从标准输入获取输入的 python 程序。现在，我必须编写另一个程序并将其作为子进程调用，这样每次我启动这个子进程时，它都应该从另一个文本文件中读取数据并将其写入标准输入，然后我的主程序从标准输入中读取并使用它。

out.py:

from subprocess import Popen, PIPE, STDOUT

import os

import sys

def read():
    p = Popen(['python', 'in.py'], stdout=PIPE, stdin=PIPE, stderr=STDOUT)

    out = p.communicate()

    print out[0]

def main():
    read()

if __name__ == "__main__":
    main()

in.py:

import sys,os

import subprocess

def main():

    f = open("ad.txt","r")

    for line in f:
        print line

if __name__ == "__main__":
    main()

基本上我的问题是in.py 读取整个文件并打印到我不想要的 STDOUT 中，而是应该传达一个字符一次。如果ad.txt 是这样的：

asdfgh

我应该得到"a"，然后是"s"，然后是"d"，然后是"f" .. 等等.. 每次我调用函数时一个接一个地读取文件中的下一个字符。就是这样！呸！！请帮助我，我有很多工作要做！在此先感谢：D

Answer 1

第一个程序应该从一个文件（或stdin）读取并写入stdout（不是stdin）。同样，第二个程序应该从stdin 读取并写入stdout。现在您可以在命令行中使用管道符号将它们粘合在一起：

python first.py | python second.py

就是这样！没有一个程序必须知道另一个程序；这就是使用“流水线”的美妙之处。

附录：Shell 流水线在缓冲区上工作。 shell 监听第一个程序并用它的输出填充缓冲区。同时，第二个程序只要有要读取的内容就从缓冲区中读取，否则它会空闲等待。通信是同时进行的，只需要固定大小的内存。

示例代码：

# first.py
import sys
for line in open("input.txt"):
    processed_line = process_line(line)
    sys.stdout.write(processed_line)

# second.py
import sys
for line in sys.stdin:
    processed_line = process_line(line)
    sys.stdout.write(processed_line)

这些示例在多行上工作（如果您使用的是文本文件，这会更好）。您可以轻松地逐字节执行相同的操作。