اعتراض stdout من عملية فرعية أثناء تشغيله

Question

إذا كانت هذه هي العملية الفرعية:

import time, sys
for i in range(200):
    sys.stdout.write( 'reading %i\n'%i )
    time.sleep(.02)

وهذا هو البرنامج النصي الذي يتحكم في إخراج العملية الفرعية وتعديله:

import subprocess, time, sys

print 'starting'

proc = subprocess.Popen(
    'c:/test_apps/testcr.py',
    shell=True,
    stdin=subprocess.PIPE,
    stdout=subprocess.PIPE  )

print 'process created'

while True:
    #next_line = proc.communicate()[0]
    next_line = proc.stdout.readline()
    if next_line == '' and proc.poll() != None:
        break
    sys.stdout.write(next_line)
    sys.stdout.flush()

print 'done'

لماذا readline و communicate الانتظار حتى يتم تشغيل العملية؟ هل هناك طريقة بسيطة لتمرير (وتعديل) Subprocess 'stdout في الوقت الفعلي؟

راجع للشغل ، لقد رأيت هذه, ، لكنني لست بحاجة إلى ميزات التسجيل (ولم يزعجها فهم الكثير منها).

أنا على Windows XP.

Answer 1

كما ذكر تشارلز سابقًا ، فإن المشكلة تخزن. ركضت في مشكلة مماثلة عند كتابة بعض الوحدات النمطية لـ SNMPD ، وحلها عن طريق استبدال stdout بإصدار التدفق التلقائي.

لقد استخدمت الكود التالي ، مستوحى من بعض المنشورات على Activestate:

class FlushFile(object):
    """Write-only flushing wrapper for file-type objects."""
    def __init__(self, f):
        self.f = f
    def write(self, x):
        self.f.write(x)
        self.f.flush()

# Replace stdout with an automatically flushing version
sys.stdout = FlushFile(sys.__stdout__)

Answer 2

إخراج العملية مخزنة. على المزيد من أنظمة التشغيل Unixy (أو Cygwin) ، Pexpect الوحدة النمطية متوفرة ، والتي تقرأ جميع التعويذات اللازمة لتجنب المشكلات المتعلقة بالتخزين المؤقت. ومع ذلك ، فإن هذه التعويذات تتطلب عمل وحدة Pty, ، وهو غير متوفر على تصميمات Win32 Python الأصلية.

في حالة المثال التي تتحكم فيها في العملية الفرعية ، يمكنك فقط الاتصال بها sys.stdout.flush() عند الضرورة - ولكن بالنسبة للعمليات الفرعية التعسفية ، فإن هذا الخيار غير متوفر.

أنظر أيضا السؤال "لماذا لا تستخدم مجرد أنبوب (popen ())؟" في الأسئلة الشائعة في PEXPECT.