Subprocess - Grep Broken Pipe

Question

Python 2.4.x这里。

一直试图让子进程与glob一起工作。

嗯，这是问题区域。

def runCommands(thecust, thedevice): 
    thepath='/smithy/%s/%s' % (thecust,thedevice) 
    thefiles=glob.glob(thepath + '/*.smithy.xml') 
    p1=subprocess.Popen(["grep", "<record>"] + thefiles, stdout=subprocess.PIPE) 
    p2=subprocess.Popen(['wc -l'], stdin=p1.stdout, stdout=subprocess.PIPE) 
    p1.stdout.close() 
    thecount=p2.communicate()[0] 
    p1.wait() 

我在屏幕上收到大量的“grep：writing output：Broken pipe”错误。

这是一些简单的东西我错过了，我只是不能发现它。任何想法？

预先感谢您。

Answer 1

这里的问题是，对于p2您的参数列表应该是['wc', '-l']而不是['wc -l']。

目前，它正在寻找一个名为'wc -l'运行一个可执行文件，并没有找到它，所以p2立即失败并没有什么连接到p1.stdout，这会导致破裂的管道失误。

试试下面的代码：

def runCommands(thecust, thedevice): 
    thepath='/smithy/%s/%s' % (thecust,thedevice) 
    thefiles=glob.glob(thepath + '/*.smithy.xml') 
    p1=subprocess.Popen(["grep", "<record>"] + thefiles, stdout=subprocess.PIPE) 
    p2=subprocess.Popen(['wc', '-l'], stdin=p1.stdout, stdout=subprocess.PIPE) 
    p1.stdout.close() 
    thecount=p2.communicate()[0] 
    p1.wait() 

Answer 2

这似乎是因为您在grep完成输出之前正在关闭p1.stdout。也许你打算关闭pt.stdin？似乎没有任何理由要关闭其中任何一个，所以我只是删除p1.stdout.close()声明。