如何处理含进度条的Docker容器日志输出？

问题根源 #

终端中进度条通过**回车符(\r，显示为^M)**让光标回到行首覆盖内容，实现单行更新；但日志文件/容器日志会保留所有\r分隔的中间内容，导致上传Gist后出现大量冗余的进度更新记录。我们需要将这类日志处理为仅保留每行的最终状态。

解决方案 #

以下提供两种Go语言实现方案，均支持处理bytes.Buffer中的日志内容：

方案1：逐字符流式处理（推荐，高效可靠）

通过维护当前行缓冲区，逐字符解析日志内容，遇到\r时重置当前行（模拟终端覆盖行为），遇到\n时固化当前行到结果中。适合大日志或流式场景，内存占用低。

import "bytes"

func ProcessProgressLog(inputBuf *bytes.Buffer) *bytes.Buffer {
    resultBuf := bytes.NewBuffer(nil)
    currentLine := bytes.NewBuffer(nil)

    for {
        b, err := inputBuf.ReadByte()
        if err != nil {
            break
        }

        switch b {
        case '\r':
            // 回车符：重置当前行，准备接收新的覆盖内容
            currentLine.Reset()
        case '\n':
            // 换行符：将当前行最终内容写入结果，重置缓冲区
            if currentLine.Len() > 0 {
                resultBuf.Write(currentLine.Bytes())
                resultBuf.WriteByte('\n')
                currentLine.Reset()
            }
        default:
            // 普通字符：追加到当前行缓冲区
            currentLine.WriteByte(b)
        }
    }

    // 处理日志末尾无换行符的最终行
    if currentLine.Len() > 0 {
        resultBuf.Write(currentLine.Bytes())
    }

    return resultBuf
}

方案2：正则表达式替换（简洁，适合小体量日志）

通过正则匹配并替换所有被\r分隔的中间内容，仅保留每行最后一次更新。需注意多次全局替换以覆盖连续\r的场景。

import (
    "bytes"
    "regexp"
)

func ProcessProgressLogWithRegex(inputBuf *bytes.Buffer) *bytes.Buffer {
    content := inputBuf.String()
    // 正则匹配：匹配任意非换行内容+回车符，且后面不是换行符（避免误处理换行前的回车）
    re := regexp.MustCompile(`([^\n]+)\r(?!\n)`)
    // 循环替换直到无匹配，确保所有中间更新被清除
    for {
        newContent := re.ReplaceAllString(content, "$1")
        if newContent == content {
            break
        }
        content = newContent
    }
    // 最后清理可能残留的单独回车符
    content = regexp.MustCompile(`\r`).ReplaceAllString(content, "")
    return bytes.NewBufferString(content)
}

使用示例 #

结合Docker SDK的场景：

// 假设已通过Docker SDK获取容器日志到logBuf（bytes.Buffer类型）
processedLog := ProcessProgressLog(logBuf)
// 后续将processedLog的内容上传至Gist即可

效果验证 #

输入日志内容（^M代表\r）：

Downloading: 10%^MDownloading: 50%^MDownloading: 100%\nProcessing: 20%^MProcessing: 70%^MProcessing: Done\n

处理后输出：

Downloading: 100%
Processing: Done

内容的提问来源于stack exchange，提问作者Santosh Kumar