如何在Golang代码中执行kubectl get events获取Kubernetes事件

1. 修复exec.Command调用错误 #

你遇到的"executable file not found"报错，核心原因是exec.Command的用法错误——第一个参数必须是可执行文件的名称/完整路径，后续命令参数需要单独传入，不能把整个命令字符串作为第一个参数。同时原代码错误后仍输出成功提示，是因为成功打印语句不在错误判断分支内，无论是否出错都会执行。修复后的代码如下：

package main

import (
    "fmt"
    "os/exec"
)

func main() {
    // 拆分命令为可执行文件+参数列表
    cmd := exec.Command("kubectl", "get", "events")
    out, err := cmd.Output()
    if err != nil {
        fmt.Printf("命令执行失败: %s\n", err)
        return // 出错后直接退出，避免错误的成功提示
    }
    fmt.Println("Command Successfully Executed")
    output := string(out)
    fmt.Println(output)
}

2. 解决kubectl路径问题 #

如果仍然报"executable file not found in $PATH"，说明系统环境变量PATH中没有包含kubectl的所在目录，你可以二选一处理：

• 将kubectl所在目录添加到系统PATH环境变量中；
• 直接使用kubectl的完整路径作为第一个参数，例如：

  cmd := exec.Command("/usr/local/bin/kubectl", "get", "events")
  

3. 更可靠的方案：使用Kubernetes Go客户端库 #

直接调用kubectl二进制文件并非最佳实践，推荐使用官方Kubernetes Go客户端库直接与API服务器交互，无需依赖kubectl二进制文件，灵活性和稳定性更高。示例代码如下：

package main

import (
    "context"
    "fmt"
    "path/filepath"

    "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/tools/clientcmd"
    "k8s.io/client-go/util/homedir"
)

func main() {
    // 加载kubeconfig配置文件
    var kubeconfig string
    if home := homedir.HomeDir(); home != "" {
        kubeconfig = filepath.Join(home, ".kube", "config")
    } else {
        fmt.Println("无法找到kubeconfig配置文件")
        return
    }

    config, err := clientcmd.BuildConfigFromFlags("", kubeconfig)
    if err != nil {
        fmt.Printf("加载配置失败: %s\n", err)
        return
    }

    // 创建Kubernetes客户端集
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        fmt.Printf("创建客户端失败: %s\n", err)
        return
    }

    // 获取所有命名空间的事件列表
    events, err := clientset.CoreV1().Events("").List(context.TODO(), v1.ListOptions{})
    if err != nil {
        fmt.Printf("获取事件失败: %s\n", err)
        return
    }

    fmt.Printf("共获取到%d个事件:\n", len(events.Items))
    for _, event := range events.Items {
        fmt.Printf("命名空间: %s | 事件类型: %s | 原因: %s | 消息: %s\n",
            event.Namespace, event.Type, event.Reason, event.Message)
    }
}

使用该方案需要先安装依赖：

go get k8s.io/client-go@latest

内容的提问来源于stack exchange，提问作者user19899551