Altprogramdan stdout'u kaydetme.Popen dosyasını dosyaya yazıp, daha fazla dosyaya

Question

dosyasına yazıyorum. Herbiri stdout üreten iki program (derlenmiş C kodundan) yürütmek için altprocess.Popen kullanan bir python komut dosyası yazıyorum. Komut bu çıktıyı alır ve bir dosyaya kaydeder. Çıktı bazen altprogram.PIPE, komut dosyasının askıda kalmasına neden olacak kadar büyük olduğundan, stdout'u doğrudan günlük dosyasına gönderirim. Komut dosyamın başlangıcına ve sonuna bir şey yazmasını istiyorum ve iki alt işlem arasında .Popen çağrıları. Ancak, günlük dosyama baktığımda, komut dosyasından günlük dosyasına yazdığım her şey, dosyanın üst kısmında, sonra da tüm yürütülebilir stdout'lar tarafından izlenir. Eklenmiş metnimi dosyaya nasıl ekleyebilirim?

def run(cmd, logfile): 
    p = subprocess.Popen(cmd, shell=True, universal_newlines=True, stdout=logfile) 
    return p 

def runTest(path, flags, name): 
    log = open(name, "w") 
    print >> log, "Calling executable A" 
    a_ret = run(path + "executable_a_name" + flags, log) 
    print >> log, "Calling executable B" 
    b_ret = run(path + "executable_b_name" + flags, log) 
    print >> log, "More stuff" 
    log.close() 

günlük dosyası vardır: yürütülebilir B çağrılması yürütülebilir bir çağrılması Daha şeyler [... Her iki yürütülebilir gelen stdout'u ...]

ben A'nın stdout'u temizlemek bir yolu var mı Örneğin, Popen'i aradıktan sonra günlük? Alakalı olabilecek bir şey daha: Çalıştırılabilir A başlangıçlar B'ye bürünüyor ve B, bir şeyler basıp bitirdikten sonra, A daha fazla şey basıyor ve bitiriyor.

RHE Linux üzerinde Python 2.4 kullanıyorum.

Answer 1

Bitirildiğinden emin olmak için her Popen nesnesinde .wait() öğesini çağırabilir ve ardından log.flush() öğesini çağırabilirsiniz. Böyle Belki bir şey:

def run(cmd, logfile): 
    p = subprocess.Popen(cmd, shell=True, universal_newlines=True, stdout=logfile) 
    ret_code = p.wait() 
    logfile.flush() 
    return ret_code 

Eğer .wait hareket olabilir sizin dış fonksiyonundaki POPEN bir nesneyle etkileşim gerekiyorsa() yerine orada diyoruz.

Answer 2

Devam etmeden önce işlem bitene kadar beklemeniz gerekir. Ayrıca kodu, daha temiz olan bir içerik yöneticisi kullanacak şekilde dönüştürdüm.

def run(cmd, logfile): 
    p = subprocess.Popen(cmd, shell=True, universal_newlines=True, stdout=logfile) 
    p.wait() 
    return p 

def runTest(path, flags, name): 
    with open(name, "w") as log: 
     print >> log, "Calling executable A" 
     a_ret = run(path + "executable_a_name" + flags, log) 
     print >> log, "Calling executable B" 
     b_ret = run(path + "executable_b_name" + flags, log) 
     print >> log, "More stuff" 

Answer 3

Sadece basit kalmasını sağlıyorum. Sözde kod temel mantığı: Sadece B çıkar sonra onun şeyi ve A çıkar yapmak B için A programı bekler Anladığım kadarıyla

write your start messages to logA 
execute A with output to logA 
write your in-between messages to logB 
execute B with output to logB 
write your final messages to logB 
when A & B finish, write content of logB to the end of logA 
delete logB 

Answer 4

.

B o zaman ters sırada süreçleri başlatabilir çalışan A olmadan başlatabilirsiniz:

from os.path import join as pjoin 
from subprocess import Popen 

def run_async(cmd, logfile): 
    print >>log, "calling", cmd 
    p = Popen(cmd, stdout=logfile) 
    print >>log, "started", cmd 
    return p 

def runTest(path, flags, name): 
    log = open(name, "w", 1) # line-buffered 
    print >>log, 'calling both processes' 
    pb = run_async([pjoin(path, "executable_b_name")] + flags.split(), log) 
    pa = run_async([pjoin(path, "executable_a_name")] + flags.split(), log) 
    print >>log, 'started both processes' 
    pb.wait() 
    print >>log, 'process B ended' 
    pa.wait() 
    print >>log, 'process A ended' 
    log.close() 

Not: Ana süreçlerde log.flush() çağıran çocuk süreçlerinde dosya tampon üzerinde hiçbir etkisi yoktur.

Alt süreçler, blok işlemleri için stdout'u kullanırsa, daha sonra pexpect, pty, or stdbuf'u kullanarak temizlemeye zorlamayı deneyebilirsiniz (bu, işlemlerin etkileşimli olarak çalıştırılırsa satır ara belleğini kullandığını veya G/Ç için C stdio kitaplığını kullandığını varsayar).