client-go入门之1：创建连接Kubernetes集群的客户端

秒速五厘米 2023-02-25 02:27 19阅读 0赞

### 文章目录 ###

*  简介
 *  使用

# 简介 #

我们可以使用Dashboard或kubectl来访问k8s的API，也可以使用编程语言，如Go,Java,Python作为客户端来访问k8s。client-go是一个使用go语言编写的库，用来连接k8s集群并对集群资源进行操作。

# 使用 #

以下代码使用go连上k8s集群，并查询集群的节点信息：

package main
    
    import (
    	"fmt"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/client-go/kubernetes"
    	"k8s.io/client-go/tools/clientcmd"
    )
    
    func main() { 
    	// 读取配置文件
    	home := GetHomePath()
    	k8sConfig, err := clientcmd.BuildConfigFromFlags("", fmt.Sprintf("%s/.kube/config", home))  // 使用 kubectl 默认配置 ~/.kube/config
    	if err != nil { 
    		fmt.Printf("%v",err)
    		return
    	}
    	
    	// 创建一个k8s客户端
    	clientSet, err := kubernetes.NewForConfig(k8sConfig)
    	if err != nil { 
    		fmt.Printf("%v",err)
    		return
    	}
    
    	// 查询k8s集群的节点信息，相当于命令：kubectl get nodes -o yaml, 如果没有管理员权限可能会失败，可以改成查Pods的接口
    	// nodes, err := clientSet.CoreV1().Nodes().List(metav1.ListOptions{}) 老版本写法
    	nodes, err := clientSet.CoreV1().Nodes().List(context.TODO(),metav1.ListOptions{ })
    	if err != nil { 
    		fmt.Printf("%v",err)
    		return
    	}
    	
    	for _,node := range nodes.Items { 
    		fmt.Println(node.Name)
    	}
    }
    
    func GetHomePath() string { 
    	u , err := user.Current()
    	if err == nil { 
    		return u.HomeDir
    	}
    	return ""
    }

主要步骤：

*  读取配置信息
 *  创建k8s客户端根据配置信息创建一个k8s客户端，并连上k8s集群：
    
        clientSet, err := kubernetes.NewForConfig(k8sConfig)
 *  调用k8s api获取集群资源信息  
    有了客户端以后，我们就可以访问k8s的资源并对其进行操作，这里我们获取一下集群的节点信息：
    
        nodes, err := clientSet.CoreV1().Nodes().List(context.TODO(),metav1.ListOptions{ })
    
    上述代码得到的信息相当于命令：`kubectl get nodes -o yaml`
 *  打印得到的资源信息，我们可以把节点的名字遍历一下打印出来看看：
    
        for _,node := range nodes.Items { 
        	fmt.Println(node.Name)
        }
    
    输出即为k8s集群的节点列表。

发表评论取消回复

表情：

评论列表（有 0 条评论，19人围观）

还没有评论，来说两句吧...

相关阅读

相关 client-go入门之1：创建连接Kubernetes集群的客户端

文章目录简介使用简介我们可以使用Dashboard或kubectl来访问k8s的API，也可以使用编程语言，如Go,Java,Python作为

秒速五厘米/ 2023年02月25日 02:27/ 0 赞/ 20 阅读

相关在jenkins中连接kubernetes集群

微信公众号搜索 DevOps和k8s全栈技术，关注之后，在后台回复 k8s视频，就可获取k8s相关视频和文档，也可扫描文章最后的二维码关注公众号。配置kubernet

秒速五厘米/ 2023年02月16日 12:22/ 0 赞/ 50 阅读

相关 Redis多集群客户端

一、pom依赖 <dependency> <groupId>org.springframework.boot</groupId>

你的名字/ 2022年12月05日 10:20/ 0 赞/ 197 阅读

相关客户端连接HDFS高可用集群

之前写过JAVA使用客户端连接Hadoop的使用，是单节点的情况；生产中使用的都是集群，网上找了好久都没找到详细的有关集群的配置方式，Hadoop nameNode HA集群中

分手后的思念是犯贱/ 2022年11月11日 10:51/ 0 赞/ 195 阅读

相关 Jenkins 使用证书连接Kubernetes集群

1、通过解码获取kubectl使用的admin证书查看 /root/.kube/config文件，文件中有三个值 certificate-authority-d

野性酷女/ 2022年10月10日 06:02/ 0 赞/ 451 阅读

相关 kubernetes 1.4 集群

> 距离上一篇 [ kubernetes 1.4 集群搭建][kubernetes 1.4] 发布间隔不算太久，自己也不断地在生产和测试环境鼓捣，有不少 “逗比” 的经历，准备

左手的ㄟ右手/ 2022年07月12日 11:13/ 0 赞/ 271 阅读

相关使用kubeadm工具箱创建kubernetes1.9集群

使用kubeadm工具箱创建kubernetes集群 [https://kubernetes.io/docs/setup/independent/install-k

￡神魔★判官ぃ/ 2022年06月01日 13:35/ 0 赞/ 233 阅读

相关 SpringCloud之客户端连接Eureka集群

[SpringCloud之客户端连接Eureka集群][SpringCloud_Eureka] 客户端分别yml：服务启动端口号 server:

本是古典何须时尚/ 2022年01月28日 13:59/ 0 赞/ 297 阅读

相关 kubernetes入门基础集群部署

二、基础集群部署 - kubernetes-simple 1. 部署ETCD（主节点） 1.1 简介 kubernetes需要存储很多东西，像它本身的节点

悠悠/ 2021年06月26日 16:06/ 0 赞/ 483 阅读

相关 Redis集群之客户端访问

我们来试试进行数据的存储 127.0.0.1:7000> set name marklogzhu OK 127.0.0.1:7000> get nam

た入场券/ 2021年05月27日 20:38/ 0 赞/ 657 阅读