`subprocess.Popen`을 사용하여 Python에서 다중 프로세스 파이프라인을 효율적으로 생성하려면 어떻게 해야 합니까?

다중 프로세스 파이프라인에 subprocess.Popen 사용

subprocess 모듈을 사용하여 파이프를 통해 여러 프로세스를 연결할 때 이러한 파이프가 어떻게 설정되는지 이해하는 것이 중요합니다. 이 경우 목표는 셸 명령을 복제하는 것입니다.

echo "input data" | awk -f script.awk | sort > outfile.txt

처음에는 이 작업을 다음과 같이 수행하려고 시도했습니다.

p_awk = subprocess.Popen(["awk","-f","script.awk"],
                          stdin=subprocess.PIPE,
                          stdout=file("outfile.txt", "w"))
p_awk.communicate( "input data" )

그러나 이 접근 방식은 파이프로만 수행됩니다. 데이터를 awk로 보내지만 출력을 정렬로 리디렉션하지 못합니다. 이 문제를 해결하기 위해 셸의 기능을 활용할 수 있습니다.

awk_sort = subprocess.Popen( "awk -f script.awk | sort > outfile.txt",
    stdin=subprocess.PIPE, shell=True )
awk_sort.communicate( b"input data\n" )

이 수정된 접근 방식은 파이프라인 구성을 셸에 위임하여 프로세스 간 원활한 데이터 전송을 처리할 수 있도록 합니다.

또한 awk 사용을 완전히 재고하는 것이 좋습니다. Python에서 필요한 처리를 직접 구현하면 코드를 단순화하고 여러 프로그래밍 언어 및 파이프라인 처리 복잡성으로 인해 발생하는 잠재적인 문제를 제거할 수 있습니다.

위 내용은 `subprocess.Popen`을 사용하여 Python에서 다중 프로세스 파이프라인을 효율적으로 생성하려면 어떻게 해야 합니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!