如何通过Golang K8sClient获取运行中Pod内指定JSON文件内容？

GetLogs是用来拉取Pod日志的，没法读取Pod内的文件。要获取/var/lib/test下的JSON文件内容，你得通过K8s客户端在Pod内部执行命令（比如cat）读取文件，再解析成Golang变量。

1. 核心思路 #

通过K8s Client的Exec接口，在Pod里执行cat /var/lib/test/xxx.json命令，捕获输出的JSON内容，最后解析到结构体或直接提取键值。

2. 完整示例代码 #

package main

import (
	"bytes"
	"context"
	"encoding/json"
	"fmt"
	corev1 "k8s.io/api/core/v1"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/tools/clientcmd"
	"k8s.io/client-go/tools/remotecommand"
	"net/http"
	"k8s.io/apimachinery/pkg/runtime/scheme"
)

func main() {
	// 加载K8s配置：本地开发用kubeconfig，集群内部署用in-cluster配置
	config, err := clientcmd.BuildConfigFromFlags("", "/home/your-user/.kube/config")
	if err != nil {
		panic(fmt.Sprintf("加载配置失败: %v", err))
	}

	// 创建K8s客户端实例
	clientset, err := kubernetes.NewForConfig(config)
	if err != nil {
		panic(fmt.Sprintf("创建客户端失败: %v", err))
	}

	// 配置你的Pod信息
	ctx := context.Background()
	namespace := "default"       // 替换成Pod所在的命名空间
	podName := "pod-0"           // 你的Pod名称
	containerName := "test-container" // 替换成Pod内的容器名（单容器可留空）
	filePath := "/var/lib/test/data.json" // 目标JSON文件路径

	// 构建执行命令的请求
	req := clientset.CoreV1().RESTClient().Post().
		Resource("pods").
		Name(podName).
		Namespace(namespace).
		SubResource("exec")

	// 设置要执行的命令：cat 目标文件
	req.VersionedParams(&corev1.PodExecOptions{
		Command:   []string{"cat", filePath},
		Container: containerName,
		Stdout:    true,
		Stderr:    true,
	}, scheme.ParameterCodec)

	// 创建命令执行器
	exec, err := remotecommand.NewSPDYExecutor(config, http.MethodPost, req.URL())
	if err != nil {
		panic(fmt.Sprintf("创建执行器失败: %v", err))
	}

	// 捕获命令的输出和错误
	var stdoutBuf, stderrBuf bytes.Buffer
	err = exec.Stream(remotecommand.StreamOptions{
		Stdout: &stdoutBuf,
		Stderr: &stderrBuf,
	})
	if err != nil {
		fmt.Printf("执行命令出错: %s\n", stderrBuf.String())
		panic(fmt.Sprintf("执行命令失败: %v", err))
	}

	// stdoutBuf里就是JSON文件的原始内容
	jsonRaw := stdoutBuf.String()
	fmt.Println("JSON文件内容:\n", jsonRaw)

	// ------------------------------
	// 解析JSON到Golang变量（可选，按需提取）
	// ------------------------------
	// 定义和JSON结构匹配的结构体（根据你的实际JSON调整字段）
	type TestConfig struct {
		AppName string `json:"app_name"`
		Version string `json:"version"`
		// 其他字段可以按需添加
	}

	var configData TestConfig
	err = json.Unmarshal([]byte(jsonRaw), &configData)
	if err != nil {
		panic(fmt.Sprintf("解析JSON失败: %v", err))
	}

	// 提取特定键的值
	fmt.Println("\n提取到的app_name值:", configData.AppName)
	fmt.Println("提取到的version值:", configData.Version)
}

3. 关键注意点 #

• 容器名必填？：如果Pod里只有一个容器，Container字段可以留空；多个容器必须指定，否则会报错。
• 命令可用性：确保Pod内的容器有cat命令（绝大多数Linux镜像都自带），如果没有可以用more或cat的替代命令。
• 权限问题：容器内的运行用户需要有读取目标JSON文件的权限，否则会返回权限拒绝错误，得调整文件权限或容器运行用户。

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