将标准输出从子进程流到python函数，然后返回到子进程

Question

我尝试在unix风格的管道中使用python。 例如，在unix中，我可以使用管道，例如：

$ samtools view -h somefile.bam | python modifyStdout.py | samtools view -bh - > processed.bam

我可以通过在python脚本中使用一个for line in sys.stdin:循环来实现这一点，它似乎可以正常工作。在

不过，我希望将这个unix命令内部化为python脚本。所以基本上我会避免进程间的大文件阻塞行为。在

目前，我试图使用Popen来管理每个命令，并将第一个进程的stdout传递给下一个进程的stdin，依此类推。在

在一个单独的python脚本中我有（sep_进程.py)公司名称：

^{pr2}$

在我的python主脚本中，我有以下内容：

import sys
from subprocess import Popen, PIPE

# Generate an example file to use
f = open('sees.txt', 'w')
f.write('somewhere over the\nrainbow')
f.close()

if __name__ == "__main__":
    # Use grep as an example command
    p1 = Popen("grep over sees.txt".split(), stdout=PIPE)

    # Send to sep_process.py 
    p2 = Popen("python ~/Documents/Pythonstuff/Bam_count_tags/sep_process.py".split(), stdin=p1.stdout, stdout=PIPE)   

    # Send to final command
    p3 = Popen("wc", stdin=p2.stdout, stdout=PIPE)

    # Read output from wc
    result = p3.stdout.read()
    print result

但是p2进程失败[Errno 2] No such file or directory，即使文件存在。在

我需要实现某种类型的Queue和/或使用多处理模块打开python函数吗？在

Answer 1

波浪号~是一个shell扩展。您没有使用shell，因此它正在查找名为~的目录。在

您可以读取环境变量HOME并插入该变量。使用

os.environ['HOME']

或者，如果您不介意自己进行扩展，可以使用shell=True。在