Wie erhalte ich Containerprotokolle mit Golang? (Fehler)

php-Editor Xigua bietet Ihnen eine praktische Anleitung zur Verwendung von Golang zum Abrufen von Containerprotokollen. Bei der Entwicklung von Containeranwendungen sind Protokolle sehr wichtig, da sie uns helfen können, Probleme schnell zu lokalisieren und zu lösen. In diesem Artikel erfahren Sie, wie Sie mit Golang Code schreiben, die Protokollinformationen des Containers über die Docker-API abrufen und häufige Fehler behandeln. Unabhängig davon, ob Sie ein Neuling oder ein erfahrener Entwickler sind, bietet Ihnen dieser Artikel nützliche Tipps und Beispielcode, die Ihnen helfen, Golang besser zum Abrufen von Containerprotokollen zu nutzen. Lass uns anfangen!

Frageninhalt

Ich versuche, Docker-Überwachungssoftware mit Golang zu schreiben.

Mein Code sieht so aus:

package main

import (
    "bytes"
    "context"
    "fmt"
    "time"

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

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

        fmt.println("the \"" + container.image + "\" container, with the id \"" + container.id + "\" logged: ")
        fmt.println()

        buf := new(bytes.buffer)

        fmt.println(buf.readfrom(out))

        fmt.println(buf.string())
    }
    time.sleep(time.second * 3)
}

Das Problem besteht darin, dass die Ausführung des obigen Codes bei der fmt.println(buf.readfrom(out))-Anweisung stoppt. Früher hat der Code funktioniert, aber plötzlich funktioniert er nicht mehr. Es stoppt entweder ohne Fehler oder gibt eine leere Zeichenfolge zurück.

Der Client, von dem ich Protokolle sammeln möchte, wurde ebenfalls von mir selbst geschrieben und sieht folgendermaßen aus:

package main

import (
    "log"
    "time"
)

func main() {
    for i := 0; i > -1; i++ {
        log.Output(1, "Hello World logged!")
        time.Sleep(time.Minute)
    }
}

Ich habe versucht, Variablen zu debuggen und zu überprüfen, aber ich kann die Ursache des Problems einfach nicht finden.

Workaround

Ich bin mir wirklich nicht sicher, da ich keine Fehlerprotokolle habe, die meine Annahme bestätigen könnten. Wenn Containerlogs jedoch einen Stream (io.readcloser) zurückgibt, ist es dann möglich, dass der Stream selbst nicht geschlossen wurde?

Könnten Sie, wenn möglich, zunächst einen Probelauf durchführen, um diese Theorie zu testen, indem Sie eine Zeitüberschreitung hinzufügen und diese nach jeder kurzen Dauer protokollieren?

Ein möglicher Weg ist

select {
case <-time.After(5 * time.Second):
    fmt.Println("Timeout exceeded while reading container logs")
case <-ctx.Done():
    fmt.Println("Context cancelled while reading container logs")
case b := <-out:
    if b != nil {
        buf.Write(b)
    }
}

Das obige ist der detaillierte Inhalt vonWie erhalte ich Containerprotokolle mit Golang? (Fehler). Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!