프로세스 출력을 읽을 때 Python 프로그램이 중단되는 것을 방지하는 방법은 무엇입니까?-파이썬 튜토리얼-php.cn

프로세스 출력을 읽을 때 Python 프로그램이 중단되는 것을 방지하는 방법은 무엇입니까?

Susan Sarandon

풀어 주다： 2024-11-02 13:54:29

원래의

527명이 탐색했습니다.

How to Avoid Python Programs from Hanging When Reading Process Output?

정지 없이 Python에서 프로세스 출력 읽기를 중지하시겠습니까?

문제:

Python 프로그램은 외부 프로그램과 상호 작용해야 합니다. 지속적으로 출력을 생성하는 프로세스(예: "top")입니다. 그러나 단순히 출력을 직접 읽는 것만으로도 프로그램이 무기한 정지될 수 있습니다.

해결책:

정지 현상을 방지하려면 다음과 같은 경우 비차단 또는 비동기 메커니즘을 사용하는 것이 필수적입니다. 프로세스 출력을 읽는 중입니다. 다음은 몇 가지 가능한 접근 방식입니다.

스풀 임시 파일(권장)

이 방법은 전용 파일 객체를 활용하여 프로세스 출력을 저장합니다.

#! /usr/bin/env python<br>하위 프로세스 가져오기<br>임시 파일 가져오기<br>가져오기 시간</p>
<p>def main():</p>
<div class="code" style="position:relative; padding:0px; margin:0px;"><pre class="brush:php;toolbar:false"># Open a temporary file (automatically deleted on closure)
f = tempfile.TemporaryFile()

# Start the process and redirect stdout to the file
p = subprocess.Popen(["top"], stdout=f)

# Wait for a specified duration
time.sleep(2)

# Kill the process
p.terminate()
p.wait()

# Rewind and read the captured output from the file
f.seek(0)
output = f.read()

# Print the output
print(output)
f.close()

로그인 후 복사

이 접근 방식은 별도의 스레드를 사용하여 프로세스 출력을 계속해서 읽습니다. 메인 스레드는 다른 작업을 진행합니다.

컬렉션 가져오기 하위 프로세스 가져오기 스레딩 가져오기 가져오기 시간 def read_output(process,append): <div class="code" style="position:relative; padding:0px; margin:0px;"><pre class="brush:php;toolbar:false">for line in iter(process.stdout.readline, ""): append(line)

# Start the process and redirect stdout process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True) # Create a thread for output reading q = collections.deque(maxlen=200) t = threading.Thread(target=read_output, args=(process, q.append)) t.daemon = True t.start() # Wait for the specified duration time.sleep(2) # Print the saved output print(''.join(q))

컬렉션 가져오기 신호 가져오기 하위 프로세스 가져오기 class Alarm(Exception): <div class="code" style="position:relative; padding:0px; margin:0px;"><pre class="brush:php;toolbar:false">pass

# Start the process and redirect stdout process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True) # Set signal handler signal.signal(signal.SIGALRM, alarm_handler) signal.alarm(2) try: # Read and save a specified number of lines q = collections.deque(maxlen=200) for line in iter(process.stdout.readline, ""): q.append(line) signal.alarm(0) # Cancel alarm except Alarm: process.terminate() finally: # Print the saved output print(''.join(q))

import collections import subprocess import threading def main(): <div class="code" style="position:relative; padding:0px; margin:0px;"><pre class="brush:php;toolbar:false"># Start the process and redirect stdout process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True) # Create a timer for process termination timer = threading.Timer(2, process.terminate) timer.start() # Read and save a specified number of lines q = collections.deque(maxlen=200) for line in iter(process.stdout.readline, ""): q.append(line) timer.cancel() # Print the saved output print(''.join(q))

import collections import subprocess import sys import time def main(): <div class="code" style="position:relative; padding:0px; margin:0px;"><pre class="brush:php;toolbar:false">args = sys.argv[1:] if not args: args = ['top'] # Start the process and redirect stdout process = subprocess.Popen(args, stdout=subprocess.PIPE, close_fds=True) # Save a specified number of lines q = collections.deque(maxlen=200) # Set a timeout duration timeout = 2 now = start = time.time() while (now - start) < timeout: line = process.stdout.readline() if not line: break q.append(line) now = time.time() else: # On timeout process.terminate() # Print the saved output print(''.join(q))