İki alt işlem arasındaki Python boru çıkışı

Question

SSH üzerinden bir blok aygıtı DD olacak bir kod üzerinde çalışıyorum ve bunu alt işlemle yapmak istiyorum, böylece aktarım sırasında DD'nin durumunu izleyebilirim. Mevcut durumu elde etmek için SIGUSR1 ile dd süreci ve seçerek kullanarak okuma).

Böyle bir şey olacağını uygulamaya çalışıyorum komut:

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

Denedim geçerli yöntem oldu: Bunu çalıştırdığınızda

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) 

Ancak SSH süreci olur 10-40 saniye sonra defunct.
Burada tamamen açık mıyım, yoksa bu gibi alt süreçler arasında boru döşemenin bir yolu yok mu?

Düzenleme: Gerçek kodumda ana bilgisayar adı bulunmadı. Bu, işleri yapmanın doğru yolu.

Answer 1

Bu, birinci işlem çıktısını ikinciye doğru BORUYI yoludur. (ssh_process in not stdin)

Answer 2

Python kitaplığı, sh Python kitaplığı, OS komutlarını çağırmayı ve bunları yönlendirmeyi kolaylaştırır. belgelerine

:

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