dongpao5261 2018-12-19 13:42
浏览 664
已采纳

如何使用Golang从Kubernetes获取日志?

I'm looking for the solution of how to get logs from a pod in Kubernetes cluster using golang. I've looked at "https://github.com/kubernetes/client-go" and "https://godoc.org/sigs.k8s.io/controller-runtime/pkg/client", but couldn't understand how to use them for this purpose. I have no issues getting information of a pod or any other object in K8S except for logs.

For example, I'm using Get() from "https://godoc.org/sigs.k8s.io/controller-runtime/pkg/client#example-Client--Get" to get K8S job info:

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

Please share of how you get pod's logs nowadays. Any suggestions would be appreciated!

Update: The solution provided in Kubernetes go client api for log of a particular pod is out of date. It have some tips, but it is not up to date with current libraries.

  • 写回答

3条回答 默认 最新

  • dongtan9066 2018-12-20 14:08
    关注

    Here is what we came up with eventually using client-go library:

    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
    }
    

    I hope it will help someone. Please share your thoughts or solutions of how you get logs from pods in Kubernetes.

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(2条)

报告相同问题?

悬赏问题

  • ¥30 关于#python#的问题:我想要的是这79个大特征对于房屋售价的最大的影响前十名(相关搜索:随机森林)
  • ¥15 使用matlab计算自定义特殊函数的二重积分,改变积分顺序所得的结果不同的问题?
  • ¥15 mysql做碎片化处理老是报错怎么办
  • ¥15 如何正确在vs2010中初始化map对象
  • ¥30 mmdet3d模型部署问题
  • ¥15 comsol仿真反射率、吸收率时峰值位置和深度不对!
  • ¥30 Visual Studio找不到sdk,如何解决?
  • ¥15 labview与机器之间网口通信发送指令
  • ¥15 迪杰斯特拉算法,考虑时延,带宽
  • ¥30 C#提交json字符串给http服务器