Go에서 장기 실행 명령의 부분 출력을 스트리밍하는 방법은 무엇입니까?

스트리밍 명령 출력 진행

장기 실행 명령이 실행되고 해당 출력이 상위 프로세스와 로그 파일 모두로 지속적으로 스트리밍되어야 하는 시나리오에서 , cmd.StdoutPipe() 메서드를 활용하여 출력을 캡처할 수 있습니다.

cmd := exec.Command("sh", "-c", "some long runnig task")

stdout, _ := cmd.StdoutPipe()
cmd.Start()

scanner := bufio.NewScanner(stdout)
for scanner.Scan() {
    m := scanner.Text()
    fmt.Println(m)
    log.Printf(m)
}

cmd.Wait()

그러나 이 접근 방식은 최종 출력은 부분 결과를 스트리밍하지 않고 단일 문자열로 출력합니다.

출력이 제한된 이유

bufio.NewScanner() 함수는 줄에서 작동하며 개행 문자가 발견되면 완전한 줄을 반환합니다. . 실행 중인 명령이 개행 문자를 생성하지 않으면 출력이 즉시 스트리밍되지 않습니다.

가능한 해결 방법

이 제한 사항을 해결하려면 다음과 같은 몇 가지 접근 방식을 고려해야 합니다.

1. 단어나 문자로 읽기:
   Scanner.Split()을 사용하는 분할 기능을 사용하면 단어나 문자로 입력을 스캔하여 생성되는 출력을 캡처할 수 있습니다.

   scanner := bufio.NewScanner(stdout)
   scanner.Split(bufio.ScanRunes)

2. 수동 읽기:
   바이트 단위 또는 룬 단위로 읽으면 줄 바꿈에 의존하지 않고 출력이 생성되는 대로 캡처할 수 있습니다.

   oneByte := make([]byte, 1)
   for {
       _, err := stdout.Read(oneByte)
       if err != nil {
           break
       }
       fmt.Printf("%c", oneByte[0])
   }
   
   oneRune := make([]byte, utf8.UTFMax)
   for {
       count, err := stdout.Read(oneRune)
       if err != nil {
           break
       }
       fmt.Printf("%s", oneRune[:count])
   }

고려 사항

하위 프로세스의 표준 출력 및 오류 스트림에 대한 버퍼 크기를 관리하는 것이 중요합니다. 기본적으로 이러한 버퍼를 읽지 않으면 하위 프로세스가 중단될 수 있습니다. 따라서 항상 stdout 및 stderr 스트림을 모두 읽는 것이 좋습니다.

위 내용은 Go에서 장기 실행 명령의 부분 출력을 스트리밍하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!