> 백엔드 개발 > Golang > Go 클라이언트를 사용하여 Kubernetes Pod에서 명령을 올바르게 실행하고 SPDY 연결을 처리하는 방법은 무엇입니까?

Go 클라이언트를 사용하여 Kubernetes Pod에서 명령을 올바르게 실행하고 SPDY 연결을 처리하는 방법은 무엇입니까?

Linda Hamilton
풀어 주다: 2024-12-14 06:22:10
원래의
997명이 탐색했습니다.

How to Correctly Execute a Command in a Kubernetes Pod Using the Go Client and Handle SPDY Connections?

Go 클라이언트를 사용하는 Kubernetes Pod의 실행 명령

문제:

제공된 코드 스니펫은 Kubernetes Go 클라이언트를 사용하여 포드 내에서 명령을 실행하려고 시도하지만 스트리밍을 시도할 때 오류가 발생합니다. 명령 출력.

해결책:

문제는 HTTP/1.1 연결용으로 고안된 remotecommand.NewExecutor()의 사용법에 있습니다. 일반적으로 Kubernetes 클러스터에서 사용되는 SPDY 연결의 경우 대신 remotecommand.NewSPDYExecutor()를 사용해야 합니다.

수정된 코드:

import (
    "fmt"
    "io"
    "os"

    container "k8s.io/api/core/v1"
    meta "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/kubernetes"
    restclient "k8s.io/client-go/rest"
    cmd "k8s.io/client-go/tools/remotecommand"
)

func main() {
    // Replace with your own config or use in-cluster config
    config := &restclient.Config{
        Host: "https://192.168.8.175:8080",
        // Insecure if using a self-signed certificate
        Insecure: true,
    }

    // Create a Kubernetes client
    client, err := kubernetes.NewForConfig(config)
    if err != nil {
        fmt.Println(err)
        return
    }

    // Define the pod and container to execute the command in
    podName := "wordpress-mysql-213049546-29s7d"
    namespace := "default"
    containerName := "mysql"

    // Define the command to execute
    command := []string{"ls"}

    // Create the PodExecOptions object
    execOptions := container.PodExecOptions{
        Container: containerName,
        Command:   []string{"ls"},
        Stdin:     true,
        Stdout:    true,
        Stderr:    true,
    }

    // Create the request
    req := client.CoreV1().RESTClient().Post().Resource("pods").Namespace(namespace).Name(podName).SubResource("exec")

    // Pass the PodExecOptions object as VersionedParams
    request := req.VersionedParams(&execOptions, meta.ParameterCodec)

    // Execute the command
    exec, err := cmd.NewSPDYExecutor(config, "POST", request.URL())
    if err != nil {
        fmt.Println(err)
        return
    }

    // Stream the output of the command to stdout and stderr
    err = exec.Stream(cmd.StreamOptions{
        Stdin:  os.Stdin,
        Stdout: os.Stdout,
        Stderr: os.Stderr,
    })
    if err != nil {
        fmt.Println(err)
        return
    }
}
로그인 후 복사

위 내용은 Go 클라이언트를 사용하여 Kubernetes Pod에서 명령을 올바르게 실행하고 SPDY 연결을 처리하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

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