Đầu ra đường ống Python giữa hai quy trình con

Question

Tôi đang làm việc trên một số mã sẽ DD thiết bị chặn qua SSH và tôi muốn thực hiện điều này với quy trình con để tôi có thể theo dõi trạng thái của DD trong quá trình truyền (giết dd quá trình với SIGUSR1 để có được trạng thái hiện tại của nó, và đọc bằng cách sử dụng các lựa chọn).

Lệnh mà tôi đang cố gắng để thực hiện sẽ là một cái gì đó như thế này:

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

Phương pháp hiện tại tôi đã cố gắng là:

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) 

Tuy nhiên khi tôi chạy này, quá trình SSH trở thành không còn tồn tại sau 10-40 giây.
Tôi có hoàn toàn bị nguyền rủa ở đây hay không có đường ống nào giữa các quá trình con như thế này?

Chỉnh sửa: Tắt mã thực của tôi không có tên máy chủ trong đó. Đây là cách làm đúng.

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() 

Đây là cách để PIPE đầu ra quá trình đầu tiên vào thứ hai. (thông báo stdin trong ssh_process)

Answer 2

sh Thư viện Python giúp dễ dàng gọi các lệnh hệ điều hành và đặt chúng.

Từ các tài liệu:

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