गो में डॉकटर कंटेनरों का प्रबंधन

दस्तावेज़ीकरण!

जब आप अपनी बाइक को डॉकटर हब से हुक पकड़ने के लिए या रजिस्ट्री से स्वचालित रूप से सर्वर पर कंटेनरों को अपडेट/शुरू करने के लिए लिखने का निर्णय लेते हैं, तो आपके सिस्टम पर डॉकर डेमन को प्रबंधित करने में मदद करने के लिए एक डॉकर क्ली काम आ सकता है।

काम करने के लिए, आपको गो संस्करण कम से कम 1.9.4 चाहिए

यदि आपने अभी भी मॉड्यूल पर स्विच नहीं किया है, तो निम्न आदेश के साथ क्ली स्थापित करें:

go get github.com/docker/docker/client

एक कंटेनर चला रहा है

निम्न उदाहरण दिखाता है कि डॉकर एपीआई का उपयोग करके कंटेनर कैसे चलाया जाए। कमांड लाइन पर, आप कमांड का प्रयोग करेंगे docker run, लेकिन हम अपनी सेवा में इस कार्य को आसानी से कर सकते हैं।
यह उदाहरण कमांड चलाने के बराबर है docker run alpine echo hello world

package main {
    ctx := context.Background()
    cli, err := client.NewEnvClient()
    if err != nil {
        panic(err)
    }

    // Делаем docker pull
    reader, err := cli.ImagePull(ctx, "docker.io/library/alpine", types.ImagePullOptions{})
    if err != nil {
        panic(err)
    }
    io.Copy(os.Stdout, reader)

    hostBinding := nat.PortBinding{
        HostIP:   "0.0.0.0",
        HostPort: "8000",
    }
    containerPort, err := nat.NewPort("tcp", "80")
    if err != nil {
        panic("Unable to get the port")
    }
    portBinding := nat.PortMap{containerPort: []nat.PortBinding{hostBinding}}

    // Создаем контейнер с заданной конфигурацией
    resp, err := cli.ContainerCreate(ctx, &container.Config{
        Image: "alpine",
        Cmd:   []string{"echo", "hello world"},
        Tty:   true,
    }, &container.HostConfig{
        PortBindings: portBinding,
    }, nil, "")
    if err != nil {
        panic(err)
    }

    // Запускаем контейнер
    if err := cli.ContainerStart(ctx, resp.ID, types.ContainerStartOptions{}); err != nil {
        panic(err)
    }

    // Получаем логи контейнера
    out, err := cli.ContainerLogs(ctx, resp.ID, types.ContainerLogsOptions{ShowStdout: true})
    if err != nil {
        panic(err)
    }
    io.Copy(os.Stdout, out)
}

चल रहे कंटेनरों की सूची प्राप्त करना

यह उदाहरण कमांड चलाने के बराबर है docker ps

package main

import (
    "context"
    "fmt"

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

func main() {
    cli, err := client.NewEnvClient()
    if err != nil {
        panic(err)
    }

    // Получение списка запуцщенных контейнеров(docker ps)
    containers, err := cli.ContainerList(context.Background(), types.ContainerListOptions{})
    if err != nil {
        panic(err)
    }

    // Вывод всех идентификаторов контейнеров
    for _, container := range containers {
        fmt.Println(container.ID)
    }
}

चलने वाले सभी कंटेनरों को रोकें

अब जब आपने कंटेनर बनाना और चलाना सीख लिया है, तो यह सीखने का समय है कि उन्हें कैसे प्रबंधित किया जाए। निम्न उदाहरण सभी चल रहे कंटेनरों को रोक देगा।

इस कोड को प्रोडक्शन सर्वर पर न चलाएं!

package main

import (
    "context"
    "fmt"

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

func main() {
    ctx := context.Background()
    cli, err := client.NewEnvClient()
    if err != nil {
        panic(err)
    }

    // Получение списка запуцщенных контейнеров(docker ps)
    containers, err := cli.ContainerList(ctx, types.ContainerListOptions{})
    if err != nil {
        panic(err)
    }

    for _, c := range containers {
        fmt.Print("Stopping container ", c.ID[:10], "... ")
        if err := cli.ContainerStop(ctx, c.ID, nil); err != nil {
            panic(err)
        }
        fmt.Println("Success")
    }
}

एकल कंटेनर के आउटपुट लॉग

आप व्यक्तिगत कंटेनरों के साथ काम कर सकते हैं। निम्न उदाहरण कंटेनर के लॉग को निर्दिष्ट आईडी के साथ प्रिंट करता है। शुरू करने से पहले, आपको उस कंटेनर की आईडी बदलनी होगी जिसके लॉग आप प्राप्त करना चाहते हैं।

package main

import (
    "context"
    "io"
    "os"

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

func main() {
    ctx := context.Background()
    cli, err := client.NewEnvClient()
    if err != nil {
        panic(err)
    }

    options := types.ContainerLogsOptions{ShowStdout: true}
    // Измените id контейнера здесь
    out, err := cli.ContainerLogs(ctx, "f1064a8a4c82", options)
    if err != nil {
        panic(err)
    }
    io.Copy(os.Stdout, out)
}

छवियों की एक सूची प्राप्त करना

यह उदाहरण कमांड चलाने के बराबर है docker image ls

package main

import (
    "context"
    "fmt"

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

func main() {
    cli, err := client.NewEnvClient()
    if err != nil {
        panic(err)
    }

    // Получение списка образов
    images, err := cli.ImageList(context.Background(), types.ImageListOptions{})
    if err != nil {
        panic(err)
    }

    for _, image := range images {
        fmt.Println(image.ID)
    }
}

खींच

यह उदाहरण कमांड चलाने के बराबर है docker pull

package main

import (
    "context"
    "io"
    "os"

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

func main() {
    ctx := context.Background()
    cli, err := client.NewEnvClient()
    if err != nil {
        panic(err)
    }

    // docker pull alpine
    out, err := cli.ImagePull(ctx, "docker.io/library/alpine", types.ImagePullOptions{})
    if err != nil {
        panic(err)
    }
    defer out.Close()
    io.Copy(os.Stdout, out)
}

उपयोगकर्ता प्रमाणीकरण के साथ एक छवि डाउनलोड करना

यह उदाहरण कमांड चलाने के बराबर है docker pull, प्रमाणीकरण के साथ।

प्रमाणीकरण डेटा स्पष्ट पाठ में भेजा जाता है। आधिकारिक डॉकटर रजिस्ट्रियां HTTPS का उपयोग करती हैं,
HTTPS का उपयोग करके संचार करने के लिए निजी रजिस्ट्रियों को भी कॉन्फ़िगर किया जाना चाहिए।

package main

import (
    "context"
    "encoding/base64"
    "encoding/json"
    "io"
    "os"

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

func main() {
    ctx := context.Background()
    cli, err := client.NewEnvClient()
    if err != nil {
        panic(err)
    }

    // Создание конфига с данными для аутентификации
    authConfig := types.AuthConfig{
        Username: "username",
        Password: "password",
    }
    encodedJSON, err := json.Marshal(authConfig)
    if err != nil {
        panic(err)
    }
    authStr := base64.URLEncoding.EncodeToString(encodedJSON)

    out, err := cli.ImagePull(ctx, "docker.io/library/alpine", types.ImagePullOptions{RegistryAuth: authStr})
    if err != nil {
        panic(err)
    }

    defer out.Close()
    io.Copy(os.Stdout, out)
}

स्रोत: www.habr.com