2つのサブプロセス間のPythonパイプ出力

Question

私はSSH上でブロックデバイスをDDにするいくつかのコードに取り組んでおり、サブプロセスでこれを行いたいので、転送中にDDのステータスを監視できますddプロセスをSIGUSR1で実行して現在の状態を取得し、selectを使用してそれを読み取る）。

私が実装しようとしているコマンドは、このようなものになるだろう：私が試した現在の方法

dd if=/dev/sda | ssh root@example.com 'dd of=/dev/sda' 

た：

dd_process = subprocess.Popen(['dd','if=/dev/sda'],0,None,None,subprocess.PIPE, subprocess.PIPE) 
ssh_process = subprocess.Popen(['ssh','root@example.com','dd of=/dev/sda'],0,None,dd_process.stdout) 

私はこれを実行したときただし、SSHプロセスになります10〜40秒後に消滅する。
私は完全にここで鈍っているのですか、またはこのようなサブプロセス間をパイプする方法はありませんか？

編集：実際のコードにはホスト名が含まれていません。これは正しいことです。

Answer 1

from subprocess import Popen, PIPE 
dd_process = Popen(['dd', 'if=/dev/sda'], stdout=PIPE) 
ssh_process = Popen(['ssh', 'root@example.com', 'dd','of=/dev/sda'],stdin=dd_process.stdout, stdout=PIPE) 
dd_process.stdout.close() # enable write error in dd if ssh dies 
out, err = ssh_process.communicate() 

これは、最初のプロセス出力を2番目のパイプにパイプする方法です。 （ssh_processのstdinに気付く）

Answer 2

sh Pythonライブラリを使用すると、OSコマンドを呼び出してパイプするのが簡単になります。ドキュメントから

：

for line in tr(tail("-f", "test.log", _piped=True), "[:upper:]", "[:lower:]", _iter=True): 
    print(line)