> 백엔드 개발 > Golang > Go 클라이언트를 사용하여 Kubernetes 포드에서 명령을 실행할 때 오류를 해결하는 방법은 무엇입니까?

Go 클라이언트를 사용하여 Kubernetes 포드에서 명령을 실행할 때 오류를 해결하는 방법은 무엇입니까?

Mary-Kate Olsen
풀어 주다: 2024-12-03 14:11:13
원래의
516명이 탐색했습니다.

How to Troubleshoot Errors When Executing Commands in Kubernetes Pods Using the Go Client?

Kubernetes Go 클라이언트를 사용하여 Pod에서 명령 실행

Kubernetes에서 exec 명령을 사용하면 Pod에서 원격으로 명령을 실행할 수 있습니다. Go 클라이언트는 이 작업을 수행하기 위한 편리한 인터페이스를 제공합니다.

다음 시나리오를 고려해보세요. wordpress-mysql-213049546-29s7d라는 Pod에서 ls 명령을 실행해야 합니다.

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())
}
로그인 후 복사

이 코드를 실행하려고 하면 메시지 없이 오류가 발생합니다. 문제에 접근하는 방법은 다음과 같습니다.

코드 디버깅

  1. Kubernetes API 서버 연결 확인: 코드가 Kubernetes API 서버와 통신할 수 있는지 확인하세요.
  2. Pod 및 네임스페이스 확인: podName 및 네임스페이스가 올바른지 다시 확인하세요. 정확합니다.
  3. 팟 매니페스트 검토: 포드 매니페스트를 검사하여 mysql 컨테이너에 ls 명령을 수행하는 데 필요한 권한이 있는지 확인하세요.

올바른 매니페스트 사용 예

또는 다음 코드 조각을 참조하여 작업할 수도 있습니다. 예:

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
}
로그인 후 복사

이 코드 샘플은 Kubernetes Go 클라이언트를 사용하여 Pod에서 명령을 성공적으로 실행하는 데 도움이 됩니다.

위 내용은 Go 클라이언트를 사용하여 Kubernetes 포드에서 명령을 실행할 때 오류를 해결하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

원천:php.cn
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
저자별 최신 기사
인기 튜토리얼
더>
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿