Go基于client-go操作Kubernetes时如何获取指定Pod日志

你已经完成了client-go的初始化和clientset构建，只需要调用Pod接口内置的日志获取方法即可，不需要额外引入第三方依赖，实现逻辑和kubectl logs命令完全对齐。

核心实现说明 #

• 构造PodLogOptions结构体指定日志拉取参数，和kubectl logs的命令参数一一对应：多容器场景必须指定Container字段明确要拉取的容器，还可以通过TailLines限制拉取最新N行、Previous拉取上一个崩溃容器的日志、Follow开启实时日志流等。
• 调用对应命名空间下Pod实例的GetLogs方法发起请求，拿到响应流后直接读取内容即可，既可以一次性读取全量日志做离线解析，也可以做流式实时消费。
• 注意及时关闭返回的日志流，避免连接泄漏。

修改后的完整可运行代码 #

import (
	"bytes"
	"context"
	"flag"
	"fmt"
	"io"
	"path/filepath"

	corev1 "k8s.io/api/core/v1"
	metav1 "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 testKubernetesRequest() {
	var kubeconfig *string
	if home := homedir.HomeDir(); home != "" {
		kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")
	} else {
		kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
	}
	flag.Parse()

	// 加载kubeconfig配置
	config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
	if err != nil {
		panic(err.Error())
	}

	// 初始化clientset
	clientset, err := kubernetes.NewForConfig(config)
	if err != nil {
		panic(err.Error())
	}

	// 获取指定Pod状态
	pod, err := clientset.CoreV1().Pods("default").Get(context.TODO(), "shell-demo", metav1.GetOptions{})
	if err != nil {
		panic(err.Error())
	}
	fmt.Println("Pod状态：", pod.Status)

	// ========== 新增：获取Pod日志逻辑 ==========
	logOptions := &corev1.PodLogOptions{
		// 多容器Pod请取消下一行注释，填入目标容器名
		// Container: "target-container-name",
		// 示例：仅拉取最近100行日志，不需要可注释
		// TailLines: func() *int64 { i := int64(100); return &i }(),
		// 示例：拉取上一次崩溃退出的容器日志，不需要可注释
		// Previous: false,
		// 示例：实时跟随日志输出，不需要可注释
		// Follow: false,
	}
	logReq := clientset.CoreV1().Pods("default").GetLogs("shell-demo", logOptions)
	logStream, err := logReq.Stream(context.TODO())
	if err != nil {
		panic(err.Error())
	}
	defer logStream.Close()

	// 读取日志内容
	logBuf := new(bytes.Buffer)
	_, err = io.Copy(logBuf, logStream)
	if err != nil {
		panic(err.Error())
	}
	podLogContent := logBuf.String()
	// 此处即可对podLogContent做自定义解析处理
	fmt.Println("=== Pod日志内容 ===")
	fmt.Println(podLogContent)
	// ========== 日志获取逻辑结束 ==========

	// 统计集群全量Pod数量
	pods, err := clientset.CoreV1().Pods("").List(context.TODO(), metav1.ListOptions{})
	if err != nil {
		panic(err.Error())
	}
	fmt.Printf("集群中共有 %d 个Pod\n", len(pods.Items))
}

注：如果你的项目引入了k8s.io/utils/ptr依赖，可以直接用ptr.To[int64](100)的方式快速生成基础类型指针，不需要自己写匿名函数转换。

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