>백엔드 개발 >파이썬 튜토리얼 >`readlines()`가 포함된 Python의 `subprocess.Popen`이 중단되는 이유는 무엇이며 어떻게 해결할 수 있습니까?

`readlines()`가 포함된 Python의 `subprocess.Popen`이 중단되는 이유는 무엇이며 어떻게 해결할 수 있습니까?

DDD
DDD원래의
2024-12-03 10:37:10147검색

Why Does Python's `subprocess.Popen` with `readlines()` Hang, and How Can I Fix It?

Python 하위 프로세스 readlines() 중단 문제

소개

파일을 스트리밍하고 한 줄씩 출력을 인쇄할 수 있습니다. 다양한 방법을 사용하여. 그러나 readlines()와 함께 하위 프로세스를 활용하면 중단 문제가 발생할 수 있습니다.

Python 스크립트

Ruby 파일 "ruby_sleep.rb"를 스트리밍하도록 설계된 Python 스크립트 "main.py"를 고려하고 출력을 인쇄합니다.

import pty
import os
from subprocess import Popen, PIPE, STDOUT

file_path = '/path/to/ruby_sleep.rb'
command = ' '.join(["ruby", file_path])

master, slave = pty.openpty()
proc = Popen(command, bufsize=0, shell=True, stdout=slave, stderr=slave, close_fds=True)     
stdout = os.fdopen(master, 'r', 0)

while proc.poll() is None:
    data = stdout.readline()
    if data != "":
        print(data)
    else:
        break

print("This line is never reached")

문제 및 관찰

실행 이 스크립트는 예상대로 Ruby 출력을 스트리밍하지만 readline() 메서드가 무기한 중단되어 "This line is neverreached" 문자열이 인쇄되지 않습니다.

솔루션 접근 방식

다양한 솔루션에는 이 정지 문제를 해결하기 위해 제안되었습니다:

1. Stdbuf를 활용

Stdbuf를 사용하면 비대화형 모드에서도 라인 버퍼링이 가능합니다.

from subprocess import Popen, PIPE, STDOUT

proc = Popen(['stdbuf', '-oL', 'ruby', 'ruby_sleep.rb'],
             bufsize=1, stdout=PIPE, stderr=STDOUT, close_fds=True)
for line in iter(proc.stdout.readline, b''):
    print line,
proc.stdout.close()
proc.wait()

2. Pexpect 채용

라인 기반 제어에 Pexpect를 사용할 수 있습니다.

import pexpect

pexpect.run("ruby ruby_sleep.rb", logfile=sys.stdout)

3. PTY 사용

PTY를 사용하면 Ruby 측에서 라인 버퍼링을 활성화하기 위해 tty를 제공할 수 있습니다.

import os
import pty
from subprocess import Popen, STDOUT

master_fd, slave_fd = pty.openpty()
proc = Popen(['ruby', 'ruby_sleep.rb'],
             stdin=slave_fd, stdout=slave_fd, stderr=STDOUT, close_fds=True)
os.close(slave_fd)
while 1:
    try:
        data = os.read(master_fd, 512)
    except OSError as e:
        if e.errno != errno.EIO:
            raise
        break # EIO means EOF on some systems
    else:
        if not data: # EOF
            break
        print('got ' + repr(data))
finally:
    os.close(master_fd)
    if proc.poll() is None:
        proc.kill()
    proc.wait()
    print("This is reached!")

위 내용은 `readlines()`가 포함된 Python의 `subprocess.Popen`이 중단되는 이유는 무엇이며 어떻게 해결할 수 있습니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.