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

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

Mary-Kate Olsen

풀어 주다： 2024-12-24 00:18:15

원래의

806명이 탐색했습니다.

How to Stream Partial Output from a Long-Running Command in 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() 함수는 줄에서 작동하며 개행 문자가 발견되면 완전한 줄을 반환합니다. . 실행 중인 명령이 개행 문자를 생성하지 않으면 출력이 즉시 스트리밍되지 않습니다.

가능한 해결 방법

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

단어나 문자로 읽기:
Scanner.Split()을 사용하는 분할 기능을 사용하면 단어나 문자로 입력을 스캔하여 생성되는 출력을 캡처할 수 있습니다.
```
scanner := bufio.NewScanner(stdout)
scanner.Split(bufio.ScanRunes)
```
로그인 후 복사

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

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])
}

로그인 후 복사