Go এ ডকার কন্টেইনার পরিচালনা করা

ডকুমেন্টেশন !

আপনি যখন ডকার হাব থেকে হুক ধরার জন্য বা সার্ভারে কনটেইনারগুলিকে স্বয়ংক্রিয়ভাবে আপডেট/চালানোর জন্য রেজিস্ট্রি থেকে আপনার নিজের বাইক লেখার সিদ্ধান্ত নেন, তখন আপনি ডকার ক্লিটিকে দরকারী বলে মনে করতে পারেন, যা আপনার সিস্টেমে ডকার ডেমন পরিচালনা করতে সহায়তা করবে৷

কাজ করার জন্য আপনার গো ভার্সন 1.9.4 এর কম নয়

আপনি যদি এখনও মডিউলগুলিতে স্যুইচ না করে থাকেন তবে নিম্নলিখিত কমান্ডটি দিয়ে Cli ইনস্টল করুন:

go get github.com/docker/docker/client

একটি ধারক চলমান

নিম্নলিখিত উদাহরণ দেখায় কিভাবে ডকার 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, প্রমাণীকরণ সহ।

প্রমাণীকরণ ডেটা পরিষ্কার পাঠ্যে পাঠানো হয়। অফিসিয়াল ডকার রেজিস্ট্রি 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