如何用Golang获取容器日志？（执行异常问题）

核心问题原因 #

1. Follow: true导致流阻塞
   当设置ContainerLogsOptions.Follow: true时，Docker API会保持日志流持续打开，等待新日志产生。buf.ReadFrom(out)会一直阻塞，直到这个流被主动关闭或者容器停止。你的测试容器每分钟才输出一条日志，所以程序会卡在这一步，直到有新日志生成；如果容器当前没有历史日志，就会返回空字符串。

2. Docker日志帧格式未处理
   Docker的日志流不是纯文本，每条日志前带有8字节的帧头部（包含流类型、日志长度等信息），直接读取会导致内容包含无效字节，甚至出现看起来为空的情况。

解决方案 #

方案1：关闭实时跟随（适合一次性获取历史日志） #

将Follow设为false，API返回完指定的Tail日志后就会关闭流，ReadFrom能正常返回：

out, err := cli.ContainerLogs(ctx, container.ID, types.ContainerLogsOptions{
    ShowStderr: true,
    ShowStdout: true,
    Timestamps: false,
    Follow:     false, // 改为false
    Tail:       "40"})

方案2：处理实时日志流（适合持续监控） #

如果需要实时监控，不能用buf.ReadFrom阻塞整个程序，需改用循环读取并解析Docker日志帧：

import (
    "bytes"
    "context"
    "encoding/binary"
    "fmt"
    "io"
    "time"

    "github.com/docker/docker/api/types"
    "github.com/docker/docker/client"
)

// 解析Docker日志帧，去除头部获取纯日志内容
func readDockerLogFrame(r io.Reader) ([]byte, error) {
    var header [8]byte
    _, err := io.ReadFull(r, header[:])
    if err != nil {
        return nil, err
    }
    // 头部第4-7字节为日志长度（大端字节序）
    logLen := binary.BigEndian.Uint32(header[4:])
    logData := make([]byte, logLen)
    _, err = io.ReadFull(r, logData)
    return logData, err
}

func main() {
    ctx := context.Background()

    cli, err := client.NewClientWithOpts(client.FromEnv)
    if err != nil {
        panic(err)
    }

    containers, err := cli.ContainerList(ctx, types.ContainerListOptions{})
    if err != nil {
        panic(err)
    }

    for _, container := range containers {
        out, err := cli.ContainerLogs(ctx, container.ID, types.ContainerLogsOptions{
            ShowStderr: true,
            ShowStdout: true,
            Timestamps: false,
            Follow:     true,
            Tail:       "40"})
        if err != nil {
            panic(err)
        }
        defer out.Close()

        fmt.Printf("The \"%s\" container (ID: %s) logged:\n\n", container.Image, container.ID)

        // 循环读取日志帧
        for {
            logData, err := readDockerLogFrame(out)
            if err != nil {
                if err == io.EOF {
                    break
                }
                panic(err)
            }
            fmt.Println(string(logData))
        }
    }
}

方案3：给上下文设置超时（避免无限阻塞） #

如果需要临时获取日志但保留Follow，可以给上下文设置超时，到时间后自动关闭流：

// 创建带5秒超时的上下文
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()

out, err := cli.ContainerLogs(ctx, container.ID, types.ContainerLogsOptions{
    ShowStderr: true,
    ShowStdout: true,
    Timestamps: false,
    Follow:     true,
    Tail:       "40"})

额外注意点 #

• 测试容器每分钟才输出一条日志，若程序卡在ReadFrom，可等待一分钟验证是否因阻塞导致；
• 使用完日志流后记得调用defer out.Close()，避免资源泄漏。

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