Kubernetes Python Client

蘋果發表於 2020-9-4 14:25:00

<h1>一、概述</h1>
Kubernetes官方维护的Python客户端client-python， 地址：https://github.com/kubernetes-client/python
<h2>安装模块</h2>
<div class="cnblogs_code">
<pre>pip3 install kubernetes</pre>
</div>
 
 
<h2>环境说明</h2>
操作系统：centos 7.6
k8s版本：1.18.1
ip地址：192.168.31.74
主机名：k8s-master
 
操作系统：centos 7.6
k8s版本：1.18.1
ip地址：192.168.31.71
主机名：k8s-node01
 
<h1>二、获取API cluster URL与token</h1>
<h2>获取Cluster URL地址</h2>
登录到k8s-master节点，执行：
<div class="cnblogs_code">
<pre># APISERVER=$(kubectl config view --minify | grep server | cut -f 2- -d ":" | tr -d " ")
# echo $APISERVER
https://192.168.31.74:6443</pre>
</div>
下面python脚本要使用，我获取的是：https://192.168.31.74:6443
 
<h2>创建k8s admin-token</h2>
编辑新文件
<div class="cnblogs_code">
<pre># mkdir -p /kube/role
# cd /kube/role
# vi admin-token.yaml</pre>
</div>
内容如下：
<div class="cnblogs_code">
<pre>kind: ClusterRoleBinding
apiVersion: rbac.authorization.k8s.io/v1beta1
metadata:
name: admin
annotations:
rbac.authorization.kubernetes.io/autoupdate: "true"
roleRef:
kind: ClusterRole
name: cluster-admin
apiGroup: rbac.authorization.k8s.io
subjects:
- kind: ServiceAccount
name: admin
namespace: kube-system
---
apiVersion: v1
kind: ServiceAccount
metadata:
name: admin
namespace: kube-system
labels:
kubernetes.io/cluster-service: "true"
addonmanager.kubernetes.io/mode: Reconcile</pre>
</div>
执行yaml文件
<div class="cnblogs_code">
<pre>kubectl create -f admin-token.yaml</pre>
</div>
 
<h2>获取token值</h2>
<div class="cnblogs_code">
<pre># kubectl describe secret/$(kubectl get secret -nkube-system |grep admin|awk '{print $1}') -nkube-system|grep token:</pre>
</div>
输出：
<div class="cnblogs_code">
<pre>token: eyJhbGciOiJSUzI1NiIsImtxxxx</pre>
</div>
由于token过长，这里用xxx代替
最后将token与APISERVER地址返回内容复制到python client主机上, 供脚本使用.
 
<h1>三、在python client主机上编写脚本</h1>
本文采用的python版本为3.7.3，运行在一台centos 7.6的服务器上面。
 
<h2>创建目录结构</h2>
<div class="cnblogs_code">
<pre># mkdir -p /kube/auth
# cd /kube/auth
# vim token.txt</pre>
</div>
将刚才获取的Token字符串复制到该文件，比如：eyJhbGciOiJSUzI1NiIsImtxxxx
这里我们获取的token会引入到我们的脚本下, 作为bearer authorization的api key与远程k8s API建立认证连接.
 
<h2>编写python client脚本</h2>
<h3>获取的命名空间</h3>
<div class="cnblogs_code">
<pre># ！/usr/bin/python3
# -*- coding: utf-8 -*-
from kubernetes.client import api_client
from kubernetes.client.apis import core_v1_api
from kubernetes import client,config

class KubernetesTools(object):
def __init__(self):
 self.k8s_url = 'https://192.168.31.74:6443'

def get_token(self):
 """
 获取token
 :return:
 """
 with open('token.txt', 'r') as file:
 Token = file.read().strip('\n')
 return Token

def get_api(self):
 """
 获取API的CoreV1Api版本对象
 :return:
 """
 configuration = client.Configuration()
 configuration.host = self.k8s_url
 configuration.verify_ssl = False
 configuration.api_key = {"authorization": "Bearer " + self.get_token()}
 client1 = api_client.ApiClient(configuration=configuration)
 api = core_v1_api.CoreV1Api(client1)
 return api

def get_namespace_list(self):
 """
 获取命名空间列表
 :return:
 """
 api = self.get_api()
 namespace_list = []
 for ns in api.list_namespace().items:
 # print(ns.metadata.name)
 namespace_list.append(ns.metadata.name)

 return namespace_list

if __name__ == '__main__':
namespace_list = KubernetesTools().get_namespace_list()
print(namespace_list)</pre>
</div>
执行输出：
<div class="cnblogs_code">
<pre>['default', 'istio-system', 'kube-node-lease', 'kube-public', 'kube-system']</pre>
</div>
 
注意：输出时，会有一段警告信息
<div class="cnblogs_code">
<pre>InsecureRequestWarning: Unverified HTTPS request is being made to host '192.168.31.74'. Adding certificate verification is strongly advised. See: https://urllib3.readthedocs.io/en/latest/advanced-usage.html#ssl-warnings
InsecureRequestWarning,</pre>
</div>
这个是requests库提示警告，因为我是ip访问的，所以SSL验证会失败。但这个不影响。
 
<h2>获取所有services</h2>
在上面的代码基础上，再加一个方法
<div class="cnblogs_code">
<pre> def get_services(self):
 """
 获取所有services
 :return:
 """
 api = self.get_api()
 ret = api.list_service_for_all_namespaces(watch=False)
 for i in ret.items:
 print("%s \t%s \t%s \t%s \t%s \n" % (
 i.kind, i.metadata.namespace, i.metadata.name, i.spec.cluster_ip, i.spec.ports))</pre>
</div>
单独执行这个方法，会输出很多信息。由于由于输出过多，这里只列出我运行的一个flaskapp
<div class="cnblogs_code">
<pre>None default flaskapp-1 10.1.168.165 [{'name': 'flaskapp-port',
'node_port': 30005,
'port': 5000,
'protocol': 'TCP',
'target_port': 5000}] </pre>
</div>
可以看到很多信息，包括service名，svc地址，以及node_port暴露的端口
 
<h2>获取pod信息</h2>
先登录k8s-master，查看目前运行的pod
<div class="cnblogs_code">
<pre># kubectl get pods
NAME READY STATUS RESTARTS AGE
flaskapp-1-5d96dbf59b-lhmp8 1/1 Running 4 23d</pre>
</div>
 
在上面的代码基础上，再加一个方法
<div class="cnblogs_code">
<pre> def get_pod_info(self,namespaces,pod_name):
 """
 查看pod信息
 :param namespaces: 命令空间，比如：default
 :param pod_name: pod完整名称，比如：flaskapp-1-5d96dbf59b-lhmp8
 :return:
 """
 api = self.get_api()
 # 示例参数
 namespaces = "default"
 pod_name = "flaskapp-1-5d96dbf59b-lhmp8"
 resp = api.read_namespaced_pod(namespace=namespaces,name=pod_name)
 #详细信息
 print(resp)</pre>
</div>
执行此方法，输出以下信息，由于输出过多，使用...省略
<div class="cnblogs_code">
<pre>{'api_version': 'v1',
'kind': 'Pod',
...</pre>
</div>
它会输出一段很长的json，里面包含了此pod的详细信息
 
<h2>获取pod日志</h2>
在上面的代码基础上，再加一个方法
<div class="cnblogs_code">
<pre> def get_pod_logs(self,namespaces,pod_name):
 """
 查看pod日志
 :param namespaces: 命令空间，比如：default
 :param pod_name: pod完整名称，比如：flaskapp-1-5d96dbf59b-lhmp8
 :return:
 """
 api = self.get_api()
 # 示例参数
 namespaces = "default"
 pod_name = "flaskapp-1-5d96dbf59b-lhmp8"
 """
 pretty美化输出
 tail_lines=200输出最近200行
 """
 log_content = api.read_namespaced_pod_log(pod_name, namespaces, pretty=True, tail_lines=200)
 print(log_content)</pre>
</div>
执行此方法，输出以下信息：
<div class="cnblogs_code">
<pre> * Serving Flask app "app" (lazy loading)
* Environment: production
WARNING: Do not use the development server in a production environment.
Use a production WSGI server instead.
* Debug mode: on
* Running on http://0.0.0.0:5000/ (Press CTRL+C to quit)
* Restarting with stat
* Debugger is active!
* Debugger PIN: 182-124-947</pre>
</div>
这个是flask运行之后，输出的日志信息。
 
想了解其他更多参考，请参考链接：
https://blog.csdn.net/sinat_33431419/article/details/105223726
 
备注：token直接写入到txt是不安全的，可以考虑将token写入到redis中，然后用python调用即可。
 
本文参考链接：
https://blog.csdn.net/hypon2016/article/details/99439309 
来源：https://www.cnblogs.com/xiao987334176/p/13613622.html

頁: [1]

琼殿技术论坛's Archiver

Kubernetes Python Client