如何在python中将输出从第一个进程（函数）传递到下一个进程（函数）？

Question

在下面的程序

1）欲输出写入到一个文件 2）而且，也想通过管道的文件的最终输出，而不是从读取下游访问输出文件中的另一过程它。

用下面的Python代码：

global product 
product = "" 
product_file = open('product.txt', 'w') 

def read_file(): 
    file1 = open ('file01.txt', 'r') 
    data1 = read.file1().rstrip('\n') 
    data1_lines = data1.split('\n) 
    for lines in data1_lines: 
     columns = lines.split('\t') 
     x = int(columns[0]) 
     y = int(columns[1]) 
     prod = x*y 
     output = open('product.txt', 'a') 
     output.write(str(x) + '\t' + str(y) + '\t' + str(prod)) 
     output.close() 
     product += str(x +'\t'+ y +'\t'+ prod +'\n') 

def manipulate_file(): 
    global product; 
    for lines in product: 
     line = product.split('\t') 
     do..something..... 

我想从def read_file()访问最终输出文件，以在下游处理（函数，即def mainpulate_file()），而不是再次打开它来使用。

我想要使用subprocess.call和/或stdin-out和/或tempfile，并最终在完成时清除内存。

我读了几个例子，但没有找到任何明确的解决过程。

我将不胜感激任何解释。

Answer 1

我们甚至不需要global的说法。

product = "" 
product_file = open('product.txt', 'w') 

def read_file(): 
    file1 = open ('file01.txt', 'r') 
    data1 = read.file1().rstrip('\n') 
    data1_lines = data1.split('\n) 
    for lines in data1_lines: 
     columns = lines.split('\t') 
     x = int(columns[0]) 
     y = int(columns[1]) 
     prod = x*y 
     output = open('product.txt', 'a') 
     output.write(str(x) + '\t' + str(y) + '\t' + str(prod)) 
     output.close() 
     product += str(x +'\t'+ y +'\t'+ prod +'\n') 
    return manipulate_file(product) 

def manipulate_file(product): 
    data = StringIO(product) 
    data_lines = data.read().rstrip('\n).split('\n') 
    for lines in data_lines: 
     do..something..... 

所以：

• 只需简单地创建一个可以在循环中更新的变量。

• 返回与定义函数

• 这个变量读它返回太多功能的文件，但这需要使用StringIO被读取，因为数据是在控制台上。

Answer 2

如果您希望能够将您当前写入product.txt的输出流水到其他进程，则必须将其写入标准输出。这是可以做到这样的：

line = str(x) + '\t' + str(y) + '\t' + str(prod) 
output.write(line) 
print(line, end='') 

的end=''部分是为了防止印刷换行符每个条目后，作为当前的代码不将它们写入文件或者。如果你真的想换行，你可以让他们像这样：

output.write(line + '\n') 
print(line) 

如果你真的只是想与输出后来在你的脚本工作，你可以进入循环前刚刚创建列表，每一行追加到名单。循环后，您可以通过执行'\n'.join(your_list)来连接所有行。