Вывод конвейера Python между двумя подпроцессами ⇐ Python

[Anonymous]

Я работаю над кодом, который будет DD блочного устройства через SSH, и я хочу сделать это с помощью подпроцесса, чтобы иметь возможность отслеживать состояние 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 секунд.

Я совершенно тупой, или нет способа организовать передачу между такими подпроцессами?

Изменить: Оказывается, в моем реальном коде не было имени хоста. Это правильный способ делать что-то.

Подробнее здесь: https://stackoverflow.com/questions/484 ... bprocesses