ការគ្រប់គ្រងធុង Docker នៅក្នុង Go

ឯកសារ!

នៅពេលអ្នកសម្រេចចិត្តសរសេរកង់ផ្ទាល់ខ្លួនរបស់អ្នកសម្រាប់ការចាប់ទំពក់ពីមជ្ឈមណ្ឌល docker ឬពីបញ្ជីឈ្មោះដើម្បីធ្វើបច្ចុប្បន្នភាព/ដំណើរការកុងតឺន័រដោយស្វ័យប្រវត្តិនៅលើម៉ាស៊ីនមេ អ្នកអាចរកឃើញ Docker Cli មានប្រយោជន៍ ដែលនឹងជួយគ្រប់គ្រង Docker daemon នៅលើប្រព័ន្ធរបស់អ្នក។

ដើម្បីដំណើរការអ្នកនឹងត្រូវការកំណែ Go មិនទាបជាង 1.9.4 ទេ។

ប្រសិនបើអ្នកនៅតែមិនទាន់ប្តូរទៅម៉ូឌុល សូមដំឡើង Cli ដោយប្រើពាក្យបញ្ជាខាងក្រោម៖

go get github.com/docker/docker/client

កំពុងដំណើរការកុងតឺន័រ

ឧទាហរណ៍ខាងក្រោមបង្ហាញពីរបៀបដំណើរការកុងតឺន័រដោយប្រើ Docker API។ នៅលើបន្ទាត់ពាក្យបញ្ជាអ្នកនឹងប្រើពាក្យបញ្ជា 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ជាមួយនឹងការផ្ទៀងផ្ទាត់។

ទិន្នន័យផ្ទៀងផ្ទាត់ត្រូវបានផ្ញើជាអត្ថបទច្បាស់លាស់។ ការចុះបញ្ជី docker ផ្លូវការប្រើ 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