Bagaimana untuk Menyelesaikan Masalah Ralat Semasa Melaksanakan Perintah dalam Kubernetes Pods Menggunakan Klien Go?

Melaksanakan Perintah dalam Pod dengan Kubernetes Go Client

Dalam Kubernetes, perintah exec membolehkan anda melaksanakan perintah dari jauh pada pod. Pelanggan Go menyediakan antara muka yang mudah untuk melaksanakan operasi ini.

Pertimbangkan senario berikut: anda perlu menjalankan arahan ls pada pod bernama wordpress-mysql-213049546-29s7d.

config := &restclient.Config{
    Host:     "http://192.168.8.175:8080",
    Insecure: true,
}

config.ContentConfig.GroupVersion = &api.Unversioned
config.ContentConfig.NegotiatedSerializer = api.Codecs

restClient, err := restclient.RESTClientFor(config)
if err != nil {
    panic(err.Error())
}

req := restClient.Post().Resource("pods").Name("wordpress-mysql-213049546-29s7d").Namespace("default").SubResource("exec").Param("container", "mysql")
req.VersionedParams(&api.PodExecOptions{
    Container: "mysql",
    Command:   []string{"ls"},
    Stdin:     true,
    Stdout:    true,
}, api.ParameterCodec)

exec, err := remotecommand.NewExecutor(config, "POST", req.URL())
if err != nil {
    panic(err.Error())
}
sopt := remotecommand.StreamOptions{
    SupportedProtocols: remotecommandserver.SupportedStreamingProtocols,
    Stdin:              os.Stdin,
    Stdout:             os.Stdout,
    Stderr:             os.Stderr,
    Tty:                false,
}

err = exec.Stream(sopt)
if err != nil {
    panic(err.Error())
}

Anda menghadapi ralat tanpa sebarang mesej apabila anda cuba melaksanakan kod ini. Begini cara untuk menangani masalah:

Menyahpepijat Kod

1. Semak Sambungan Pelayan API Kubernetes: Pastikan kod anda boleh berkomunikasi dengan pelayan API Kubernetes.
2. Sahkan Pod dan Ruang Nama: Periksa semula bahawa podName dan ruang nama adalah betul.
3. Semak Manifes Pod: Periksa manifes pod untuk mengesahkan bahawa bekas mysql mempunyai kebenaran yang diperlukan untuk melaksanakan perintah ls.

Menggunakan Contoh yang Betul

Sebagai alternatif, anda boleh merujuk kepada coretan kod berikut untuk contoh berfungsi:

import (
    "io"

    v1 "k8s.io/api/core/v1"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/kubernetes/scheme"
    restclient "k8s.io/client-go/rest"
    "k8s.io/client-go/tools/remotecommand"
)

// ExecCmd exec command on specific pod and wait the command's output.
func ExecCmdExample(client kubernetes.Interface, config *restclient.Config, podName string,
    command string, stdin io.Reader, stdout io.Writer, stderr io.Writer) error {
    cmd := []string{
        "sh",
        "-c",
        command,
    }
    req := client.CoreV1().RESTClient().Post().Resource("pods").Name(podName).
        Namespace("default").SubResource("exec")
    option := &v1.PodExecOptions{
        Command: cmd,
        Stdin:   true,
        Stdout:  true,
        Stderr:  true,
        TTY:     true,
    }
    if stdin == nil {
        option.Stdin = false
    }
    req.VersionedParams(
        option,
        scheme.ParameterCodec,
    )
    exec, err := remotecommand.NewSPDYExecutor(config, "POST", req.URL())
    if err != nil {
        return err
    }
    err = exec.Stream(remotecommand.StreamOptions{
        Stdin:  stdin,
        Stdout: stdout,
        Stderr: stderr,
    })
    if err != nil {
        return err
    }

    return nil
}

Sampel kod ini seharusnya membantu anda melaksanakan perintah pada pod menggunakan klien Kubernetes Go dengan jayanya.

Atas ialah kandungan terperinci Bagaimana untuk Menyelesaikan Masalah Ralat Semasa Melaksanakan Perintah dalam Kubernetes Pods Menggunakan Klien Go?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!