Python에서 Ruby 파일을 스트리밍할 때 `subprocess.readlines()`가 중단되는 이유는 무엇입니까?

Python subprocess.readlines()가 중단됨

문제:

다음 Python 코드에서 , Ruby 파일을 스트리밍하기 위해 subprocess.readlines()를 사용하면 프로그램이 중단됩니다. 무기한으로 최종 print 문이 실행되는 것을 방지합니다:

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

file_path = '/Users/luciano/Desktop/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 is never reached!")

원인:

여기서 문제는 pty 사용에서 비롯됩니다. 터미널 처리. 이로 인해 일반적으로 Ruby 측에서 라인 버퍼링이 발생하여 readline() 함수가 개행 문자를 무기한 기다리게 됩니다.

해결책:

여러 가지 옵션이 있습니다. 이 문제를 해결하려면:

1. pexpect 사용:

pexpect는 비대화형 설정에서 라인 버퍼링을 활성화합니다.

import sys
import pexpect

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

2. 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()

3. 표준 라이브러리에서 pty 사용:

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

master_fd, slave_fd = pty.openpty()  # provide tty to enable
                                     # line-buffering on ruby's side
proc = Popen(['ruby', 'ruby_sleep.rb'],
             stdin=slave_fd, stdout=slave_fd, stderr=STDOUT, close_fds=True)
os.close(slave_fd)
try:
    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!")

위 내용은 Python에서 Ruby 파일을 스트리밍할 때 `subprocess.readlines()`가 중단되는 이유는 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!