Nhận thông báo tiến bộ từ một tiến trình con

Question

Tôi muốn bắt đầu một chương trình cần vài phút để hoàn tất. Trong thời gian này, tôi muốn đọc thông báo tiến độ của chương trình (được in trên stdout). Vấn đề là tôi không thể tìm ra cách đọc đầu ra của nó trong khi chạy.

Chức năng duy nhất tôi tìm thấy để đọc đầu ra của chương trình là Popen.communicate(), nhưng phương pháp này chờ cho đến khi quá trình kết thúc. Vì vậy, nó là không thể có được sự tiến bộ và làm cho nó có thể nhìn thấy cho người sử dụng trong một cách định dạng đặc biệt.

Có thể thực hiện điều này theo cách khác không?

Khi tôi chạy quy trình với subprocess.popen bằng tập lệnh của mình, tôi thấy đầu ra của chương trình trên màn hình. Có thể giấu nó không? (Ubuntu 10.10, thiết bị đầu cuối thông thường)

Answer 1

Đơn giản nhất là gọi Popen bằng đối số từ khóa stdout=subprocess.PIPE.

p = subprocess.Popen(["ls"], stdout=subprocess.PIPE) 
while True: 
    line = p.stdout.readline() 
    if not line: 
     break 
    print line 

---

Để thấy điều này trong hành động, đây là hai kịch bản mẫu. Làm cho họ cả trong cùng thư mục và chạy python superprint.py

printandwait.py:

import time 
import sys 
print 10 
sys.stdout.flush() 
time.sleep(10) 
print 20 
sys.stdout.flush() 

superprint.py:

import subprocess 
import sys 
p = subprocess.Popen(["python printandwait.py"], shell=True, stdout=subprocess.PIPE) 
while True: 
    print "Looping" 
    line = p.stdout.readline() 
    if not line: 
     break 
    print line.strip() 
    sys.stdout.flush() 

Answer 2

Bạn có thể thực hiện cuộc thăm dò ý kiến ​​về trạng thái của quy trình con và giữ các đường xuất.

p = subprocess.Popen('ls;sleep 10', shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE) 

rc = p.poll() 
while rc != 0: 
    while True: 
     line = p.stdout.readline() 
     if not line: 
      break 
     print line 
    rc = p.poll() 

assert rc == 0 

Answer 3

Đó chắc chắn có thể: gói của tôi python-gnupg thực hiện chính xác này, đẻ trứng gpg (Gnu Privacy Guard) trong một tiến trình con. Trong trường hợp chung, bạn cần phải chỉ định subprocess.PIPE cho stdout subprocess và stderr; sau đó tạo ra hai chủ đề riêng biệt mà đọc stdout subprocess và stderr đến bất cứ nơi nào bạn muốn.

Trong trường hợp python-gnupg, thông báo trạng thái từ gpg được đọc và hành động trong khi quá trình gpg đang chạy (không đợi cho đến khi hoàn tất).

Về cơ bản, giả là

process = subprocess.Popen(..., stdout=subprocess.PIPE, stderr=subprocess.PIPE) 
stderr = process.stderr 
rr = threading.Thread(target=response_reader_func, args=(process.stderr,)) 
rr.setDaemon(True) 
rr.start() 

dr = threading.Thread(target=data_reader_func, args=(process.stdout,)) 
dr.setDaemon(True) 
dr.start() 

dr.join() 
rr.join() 
process.wait() 

Các chức năng đọc thường phương pháp của một lớp kèm theo đó làm điều đúng dựa trên những gì họ đang đọc (trong trường hợp của bạn, cập nhật thông tin tiến bộ một cách nào đó).