दो subprocesses

Question

के बीच पाइथन पाइपिंग आउटपुट मैं कुछ कोड पर काम कर रहा हूं जो एसएसएच पर एक ब्लॉक डिवाइस डीडी करेगा, और मैं इसे सबप्रोसेस के साथ करना चाहता हूं ताकि मैं स्थानांतरण के दौरान डीडी की स्थिति की निगरानी कर सकूं (हत्या एसआईजीयूएसआर 1 के साथ डीडी प्रक्रिया को वर्तमान स्थिति प्राप्त करने के लिए, और चयन का उपयोग करके पढ़ना)।

आदेश है कि मैं लागू करने के लिए कुछ इस तरह होगा कोशिश कर रहा हूँ:

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

यह दूसरी प्रक्रिया को पीआईपीई करने का तरीका है। (ssh_process में stdin नोटिस)

Answer 2

sh पायथन लाइब्रेरी ओएस कमांड को कॉल करना और उन्हें पाइप करना आसान बनाता है।

प्रलेखन से:

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