client-go获取k8s集群内部连接,实现deployment的增删改查
凝风 人气:3一开始写了一个client-java版本的,但是java放在k8s集群上跑需要装jvm而且java的包比较大,client-go版本更适合主机端,下面是整个实现
说明:k8s官方维护的客户端库只有go和python版本,所以为了稳定性建议使用这两个版本,考虑到k8s是go实现的,我这里也就选择go版本。至于客户端连接k8s集群,在具体的生产环境中不建议外部连接访问。原因一是生产环境中的k8s配置文件重要,一般如果对接其他公司的业务,虽然有鉴权,人家也不愿意把配置文件拷贝给你,因为有了集群的配置文件,外部的这个项目的权限就很大,相当于给集群开了一个隐患口子,要知道k8s集群中有可能是该公司的整个业务。原因二集群内部访问不需要那么复杂的鉴权,反而更省事点,只需要写个小应用部署到k8s集群中即可。应用已经在集群内部了,就没有鉴权的概念了,其他三方服务只需要调用小应用的api即可操作k8s。
1. 构建goWeb小应用导入依赖:
a. 不管是走go的代理还是其他办法,这里默认能搭建goWeb项目,并且能够使用go mod tidy拉取包。
b. 按照官方文档导入依赖这里我用的是0.17.0版本,此处有坑,不仅仅这个版本有这个坑,其他版本很有可能也有,完全正常的导入但是会存在jar包之间版本不一致问题,这个问题会导致go build无法构建,是官方自身的兼容问题,报错信息为:
# k8s.io/client-go/rest
../../../../goworkspace/pkg/mod/k8s.io/client-go@v11.0.0+incompatible/rest/request.go:598:31: not enough arguments in call to watch.NewStreamWatcher
have (*versioned.Decoder)
want (watch.Decoder, watch.Reporter)
c. 可以尝试手动替换k8s.io/apimachinery@v0.17.0为k8s.io/apimachinery@release-1.14来解决。在终端执行# go mod download -json k8s.io/apimachinery@release-1.14最终gomod的关于k8s的所有依赖文件如下所示:
1 require ( 2 k8s.io/api v0.17.0 // indirect 3 k8s.io/apimachinery v0.17.0 4 k8s.io/client-go v11.0.0+incompatible 5 k8s.io/utils v0.0.0-20191114184206-e782cd3c129f // indirect 6 sigs.k8s.io/yaml v1.1.0 // indirect 7 ) 8 9 replace ( 10 k8s.io/api => k8s.io/api v0.0.0-20191004102349-159aefb8556b 11 k8s.io/apiextensions-apiserver => k8s.io/apiextensions-apiserver v0.0.0-20191004105649-b14e3c49469a 12 k8s.io/apimachinery => k8s.io/apimachinery v0.0.0-20191004074956-c5d2f014d689 13 sigs.k8s.io/controller-runtime => sigs.k8s.io/controller-runtime v0.3.0 14 )
这里参考博客为:https://segmentfault.com/a/1190000021077653?utm_source=tag-newest
最终go build就没问题了。
2. 配置集群内部访问的客户端
a. 内部访问k8s客户端使用defaultClient即可,但是这里第二个坑,client-go里面默认的客户端寻找的是~/.kube下的config文件,并且需要集群的ip和port,也就是说需要人为的去配置环境变量以便满足ip和port的写入需要,需要提前把config放到~/.kube下。恰巧客户的环境也没配置环境变量,也没把config拷到响应的目录下,只能找其他办法。由于之前写过一个java的客户端调用,里面的defaultClient是可以访问到的。所以看下java中的寻找路径,发现了一个上下文路径的东西。最终改造client-go客户端信息如下:
1 package utils 2 3 import ( 4 "k8s.io/client-go/kubernetes" 5 "k8s.io/client-go/tools/clientcmd" 6 "log" 7 "os" 8 "path/filepath" 9 ) 10 11 // 获取集群内部k8s客户端 12 func K8sClient() *kubernetes.Clientset { 13 // 使用当前上下文环境 14 kubeconfig := filepath.Join( 15 os.Getenv("KUBECONFIG"), 16 ) 17 config, err := clientcmd.BuildConfigFromFlags("", kubeconfig) 18 if err != nil { 19 log.Fatal(err) 20 } 21 // 根据指定的 config 创建一个新的 clientSet 22 clientSet, err := kubernetes.NewForConfig(config) 23 if err != nil { 24 panic(err.Error()) 25 } 26 return clientSet 27 }
其中os.Getenv就是拿k8s的默认配置文件,只要该应用部署在k8s集群环境中,这个客户端就可以正确返回和使用。
3. pod列表,deployment列表,deployment扩缩容等实现
1 // 拿客户端 2 clientSet := utils.K8sClient() 3 //获取PODS列表,不传namespace默认查全部 4 pods, err := clientSet.CoreV1().Pods(nameSpace).List(metav1.ListOptions{}) 5 if err != nil { 6 log.Println(err.Error()) 7 } 8 // deployment列表获取 9 deploymentsClient := clientSet.AppsV1().Deployments(nameSpace) 10 deployments, err := deploymentsClient.List(metav1.ListOptions{}) 11 if err != nil { 12 panic(err) 13 } 14 // deployment详情获取 15 deploymentsClient := clientSet.AppsV1().Deployments(nameSpace) 16 deployment, err := deploymentsClient.Get(deploymentName, metav1.GetOptions{}) 17 if err != nil { 18 panic(err) 19 } 20 // 扩缩容,num是扩缩容至多少 21 deploymentsClient := clientSet.AppsV1().Deployments(nameSpace) 22 retryErr := retry.RetryOnConflict(retry.DefaultRetry, func() error { 23 result, getErr := deploymentsClient.Get(deploymentName, metav1.GetOptions{}) 24 if getErr != nil { 25 panic(fmt.Errorf("失败,确认之后再试一下呗~: %v", getErr)) 26 } 27 result.Spec.Replicas = int32Ptr(int32(num)) 28 _, updateErr := deploymentsClient.Update(result) 29 return updateErr 30 }) 31 if retryErr != nil { 32 panic(fmt.Errorf("扩容出现问题,请检查调用~: %v", retryErr)) 33 }
亲测可用~,点个赞呗~
加载全部内容