前言：
K8s也提供API接口，提供这个接口的是管理节点的apiserver组件，apiserver服务负责提供HTTP API，以便用户、其他组件相互通信。客户端库
安装
|
1
|
pip install kubernetes -i https://pypi.douban.com/simple |
k8s认证方式：
- HTTPS 证书认证：基于CA证书签名的数字证书认证
- HTTP Token认证：通过一个Token来识别用户
HTTPS证书认证（kubeconfig）
|
1
2
3
4
5
6
7
|
import osfrom kubernetes import client, configconfig.load_kube_config(file_path) # 指定kubeconfig配置文件apps_api = client.AppsV1Api() # 资源接口类实例化for dp in apps_api.list_deployment_for_all_namespaces().items: print(dp) |
HTTP Token认证（ServiceAccount）
|
1
2
3
4
5
6
7
8
|
from kubernetes import client, configconfiguration = client.Configuration()configuration.host = "https://192.168.3.201:16443" # APISERVER地址configuration.ssl_ca_cert="ca.crt" # CA证书 /etc/kubernetes/pki/ca.crtconfiguration.verify_ssl = True # 启用证书验证configuration.api_key = {"authorization": "Bearer " + token} # 指定Token字符串client.Configuration.set_default(configuration)apps_api = client.AppsV1Api() |
这2个认证，2选1
获取Token字符串：创建service account并绑定默认cluster-admin管理员集群角色：
创建用户：
$ kubectl create serviceaccount dashboard-admin -n kube-system
用户授权：
$ kubectl create clusterrolebinding dashboard-admin --clusterrole=cluster-admin --serviceaccount=kube-system:dashboard-admin
获取用户Token：
$ kubectl describe secrets -n kube-system $(kubectl -n kube-system get secret | awk ‘/dashboard-admin/{print $1}’)
其他常用资源接口类实例化：
|
1
2
3
4
|
core_api = client.CoreV1Api() # namespace,pod,service,pv,pvcapps_api = client.AppsV1Api() # deploymentnetworking_api = client.NetworkingV1beta1Api() # ingressstorage_api = client.StorageV1Api() # storage_class |
举个例子
Deployment操作：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
# 先得有上面的认证，下面的代码才行# 创建namespace = "default"name = "api-test"replicas = 3labels = {'nginx':'true'} # 不区分数据类型，都要加引号image = "nginx"body = client.V1Deployment( api_version="apps/v1", kind="Deployment", metadata=client.V1ObjectMeta(name=name), spec=client.V1DeploymentSpec( replicas=replicas, selector={'matchLabels': labels}, template=client.V1PodTemplateSpec( metadata=client.V1ObjectMeta(labels=labels), spec=client.V1PodSpec( containers=[client.V1Container( name="web", image=image )] ) ), ) )try: apps_api.create_namespaced_deployment(namespace=namespace, body=body)except Exception as e: status = getattr(e, "status") if status == 400: print(e) print("格式错误") elif status == 403: print("没权限")# 删除name = "api-test"apps_api.delete_namespaced_deployment(namespace=namespace, name=name) |
但其实这个API挺绕的 ，一个创建deployment的，这里N多的类的对象。
到此这篇关于python调用kubernetesAPI简单使用方法的文章就介绍到这了,更多相关python调用kubernetesAPI 内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家！
原文链接：https://blog.csdn.net/hans99812345/article/details/124851132
