PopenによるPython grepとpipe

Question

私はディレクトリからgrepしようとしており、検索結果を最初の100件に制限しようとしています。

p_grep = Popen(['/bin/bash', '-c', 'grep -F "asdasdasd" data/*'], stdout = PIPE) 
p_head = Popen(['head', '-100'], stdin = p_grep.stdout, stdout = PIPE) 
output = p_head.communicate()[0] 

はどのようにそれを修正するには：次のコードは、

[..] 
grep: writing output: Broken pipe 
grep: writing output: Broken pipe 
grep: writing output: Broken pipe 
grep: writing output: Broken pipe 
[..] 

コードを得続けますか？あなたが行うことができます。この場合、実際に

Answer 1

：

output = check_output(['/bin/bash', '-c', 'grep -F "asdasdasd" data/* | head -100']) 

Answer 2

彼らはSIGPIPEを受信することができるようにPopen documentation on writing pipesあなたは（この場合はp_grepに）パイプで連結されたプロセスにstdoutを閉じて確認する必要がありますによると、パイプされたプロセス（この場合はp_head）から取得します。

さらに、this postによれば、各サブプロセスにセットアップ機能を提供して、SIGPIPEの処理がデフォルトの動作に復元されるようにすることが重要です。

だからコードは次のようになります。grepプロセスは一度head完了を終了させる必要があります

def preexec_fn(): 
    import signal 
    signal.signal(signal.SIGPIPE, signal.SIG_DFL) 

p_grep = Popen(['/bin/bash', '-c', 'grep -F "asdasdasd" data/*'], stdout=PIPE, preexec_fn=preexec_fn) 
p_head = Popen(['head', '-100'], stdin=p_grep.stdout, stdout=PIPE, preexec_fn=preexec_fn) 
p_grep.stdout.close() 
output = p_head.communicate()[0] 

。