Golang 代码解析 JSON 格式的 Docker 容器日志

最近发现不少小伙伴都对Golang很感兴趣，所以今天继续给大家介绍Golang相关的知识，本文《Golang 代码解析 JSON 格式的 Docker 容器日志》主要内容涉及到等等知识点，希望能帮到你！当然如果阅读本文时存在不同想法，可以在评论中表达，但是请勿使用过激的措辞~

我需要获取 docker 容器的日志，我使用下面的代码来获取 docker 日志，

ctx := context.background()
cli, err := client.newclientwithopts(client.fromenv, client.withapiversionnegotiation())
if err != nil {
    panic(err)
}

options := types.containerlogsoptions{
    showstdout: true,
    showstderr: true,
    since:      "",
    until:      "",
    timestamps: false,
    follow:     true,
    tail:       "",
    details:    true,
}

out, err := cli.containerlogs(ctx, "bcd693465a62", options)
if err != nil {
    panic(err)
}

buf := new(strings.builder)
_, err = io.copy(buf, out)
if err != nil {
    fmt.println(err)
}
fmt.printf("%s", buf)

我的问题是我收到两种不同格式的 docker 日志，对于某些容器来说它只是纯文本

exec /entrypoint.sh: no such file or directory

但在containerid-json.log文件中，它以以下格式显示

{"log":"exec /entrypoint.sh: no such file or directory\n","stream":"stderr","time":"2022-09-06t12:23:57.741316145z"}

对于某些容器，它以动态格式/模式显示

time="2022-09-05t02:13:44z" level=debug msg="cleanup aborting ingest" ref="buildkit/1/layer-sha256:2774afd0c4d3ded992c58f3b5e5939d091bd26f40e507c6dc21dcbd8b7ff486f"

time="2022-09-05t02:13:44z" level=debug msg="content garbage collected" d=2.971574ms

如何以相同的架构/格式收集所有 docker 容器的日志，以便将其存储为以下 json 格式？

{
    "containerID": "bcd693465a62",
    "logs": [
        {"log":"exec /entrypoint.sh: no such file or directory\n","stream":"stderr","time":"2022-09-06T12:23:57.741316145Z"},
        {"log":"cleanup aborting ingest","stream":"stdout","time":"2022-09-05T02:13:44Z"}
    ]
}

感谢任何帮助

正确答案

我在@brianwagner的代码参考的帮助下编写了下面的代码来满足我的要求（它按预期工作），请建议是否可以做得更好，或者是否有任何改进。

package main

import (
    "context"
    "encoding/binary"
    "fmt"
    "io"
    "log"
    "strings"

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

type DockerContainerLog struct {
    ContainerID string      `json:"containerID"`
    DockerLogs  []DockerLog `json:"dockerLogs"`
}

type DockerLog struct {
    Time   string `json:"time"`
    Stream string `json:"stream"`
    Log    string `json:"log"`
}

func main() {
    logs := getContainerLogs("cd3d8362ba45")
    fmt.Print(logs)
}

func getContainerLogs(cid string) DockerContainerLog {
    cli, err := client.NewClientWithOpts(client.FromEnv, client.WithAPIVersionNegotiation())
    if err != nil {
        panic(err)
    }

    options := types.ContainerLogsOptions{
        ShowStdout: true,
        ShowStderr: true,
        Since:      "",
        Until:      "",
        Timestamps: true,
        Follow:     true,
        Tail:       "",
        Details:    false,
    }

    reader, err := cli.ContainerLogs(context.Background(), cid, options)
    if err != nil {
        log.Fatal(err)
    }
    defer reader.Close()

    dockerLogs := DockerContainerLog{ContainerID: cid}

    hdr := make([]byte, 8)
    for {
        var docLog DockerLog
        _, err := reader.Read(hdr)
        if err != nil {
            if err == io.EOF {
                return dockerLogs
            }

            log.Fatal(err)
        }

        count := binary.BigEndian.Uint32(hdr[4:])
        dat := make([]byte, count)
        _, err = reader.Read(dat)
        if err != nil && err != io.EOF {
            log.Fatal(err)
        }

        time, log, found := strings.Cut(string(dat), " ")
        if found {
            docLog.Time = time
            docLog.Log = log
            switch hdr[0] {
            case 1:
                docLog.Stream = "Stdout"
            default:
                docLog.Stream = "Stderr"
            }

            dockerLogs.DockerLogs = append(dockerLogs.DockerLogs, docLog)
        }
    }
}

到这里，我们也就讲完了《Golang 代码解析 JSON 格式的 Docker 容器日志》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！