首頁 > 後端開發 > Golang > 如何使用Go客戶端在Kubernetes Pod中正確執行指令並處理SPDY連線?

如何使用Go客戶端在Kubernetes Pod中正確執行指令並處理SPDY連線?

Linda Hamilton
發布: 2024-12-14 06:22:10
原創
1002 人瀏覽過

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

使用Go 客戶端在Kubernetes Pod 中執行命令

問題:

提供的程式碼snippet 嘗試使用Kubernetes Go 用戶端在pod內執行命令,但在嘗試串流時遇到錯誤命令輸出。

解決方案:

問題在於使用了remotecommand.NewExecutor(),該函數適用於HTTP/1.1 連接。對於 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
作者最新文章
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板