如何使用 Go 从 Kubernetes 获取日志？

偷偷努力，悄无声息地变强，然后惊艳所有人！哈哈，小伙伴们又来学习啦~今天我将给大家介绍《如何使用 Go 从 Kubernetes 获取日志？》，这篇文章主要会讲到golang等等知识点，不知道大家对其都有多少了解，下面我们就一起来看一吧！当然，非常希望大家能多多评论，给出合理的建议，我们一起学习，一起进步！

问题内容

我正在寻找如何使用 Go 从 Kubernetes 集群中的 pod 获取日志的解决方案。我看过“https://github.com/kubernetes/client- go”和“https://godoc.org/sigs.k8s.io/controller- runtime/pkg/client”，但不明白如何将它们用于此目的。除了日志，我在 K8S 中获取 pod 或任何其他对象的信息都没有问题。

例如，我使用“https://godoc.org/sigs.k8s.io/controller-runtime/pkg/client#example- Client--Get”中的 Get() 来获取 K8S 作业信息：

found := &batchv1.Job{}
err = r.client.Get(context.TODO(), types.NamespacedName{Name: job.Name, Namespace: job.Namespace}, found)

请分享您现在如何获取 pod 的日志。任何建议，将不胜感激！

更新：[Kubernetes go client api 中为特定 pod 的日志](https://stackoverflow.com/questions/32983228/kubernetes-go-client-api- for-log-of-a-particular-pod)提供的解决方案已过时。它有一些提示，但它与当前的库不是最新的。

正确答案

这是我们最终使用 client-go 库得出的结论：

func getPodLogs(pod corev1.Pod) string {
    podLogOpts := corev1.PodLogOptions{}
    config, err := rest.InClusterConfig()
    if err != nil {
        return "error in getting config"
    }
    // creates the clientset
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        return "error in getting access to K8S"
    }
    req := clientset.CoreV1().Pods(pod.Namespace).GetLogs(pod.Name, &podLogOpts)
    podLogs, err := req.Stream()
    if err != nil {
        return "error in opening stream"
    }
    defer podLogs.Close()

    buf := new(bytes.Buffer)
    _, err = io.Copy(buf, podLogs)
    if err != nil {
        return "error in copy information from podLogs to buf"
    }
    str := buf.String()

    return str
}

我希望它会帮助某人。请分享您对如何从 Kubernetes 中的 pod 获取日志的想法或解决方案。

今天带大家了解了golang的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~