php小编鱼仔在使用pod运行特定命令时遇到了错误。这个问题对于开发人员来说是非常常见的，但解决起来可能会有些困难。当我们在pod中执行特定命令时出现错误，这可能是由于多种因素引起的，比如版本不兼容、依赖关系问题等。在解决这个问题之前，我们需要先确定具体的错误信息，然后逐步排查和解决。在本文中，我们将介绍一些常见的错误情况和相应的解决方案，希望能帮助到遇到类似问题的开发人员。

问题内容

我正在尝试在正在运行的 pod 中执行命令。我正在使用 go k8sclient 来实现此目的，但遇到了问题。我也不知道解决方案是否正确。任何人都可以检查并提供正确的解决方案吗？

这是我的代码。

namespace := getnamespace()
        podname := "maxscale-0"

        config, err := rest.inclusterconfig()
        if err != nil {
                log.fatal(err)
        }

        clientset, err := kubernetes.newforconfig(config)
        if err != nil {
                log.fatal(err)
        }



        req := clientset.corev1().pods(namespace).exec(podname, &corev1.podexecoptions{
                command: []string{"sh", "-c", "grep -op '"name": "k[^"]*' /var/lib/maxscale/mariadb-monitor_journal.json"},
        })

        // set up a stream to capture the output
        execstream, err := req.stream()
        if err != nil {
                fmt.println(err)
                os.exit(1)
        }

        // print the output
        buf := new(bytes.buffer)
        buf.readfrom(execstream)
        fmt.println(buf.string())

我得到的错误是

clientset.CoreV1().Pods(namespace).Exec undefined (type "k8s.io/client-go/kubernetes/typed/core/v1".PodInterface has no field or method Exec)

解决方法

正如 @david maze 所分享的，要使用 k8 的 go 客户端在 pod 中执行命令，请遵循以下代码：

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
}

另请参阅此链接了解更多信息