python3 kubernetes獲取service、pod、deployment

1、查看

kube_conf = '/root/kubeconfig.yaml'
config.load_kube_config(kube_conf)
api = client.AppsV1Api()
core = client.CoreV1Api()


def list_namespace():
    ret = []
    for ns in core.list_namespace().items:
        ret.append(ns.metadata.name)
    return ret


def list_services():
    result = []
    ret = core.list_service_for_all_namespaces(watch=False)
    for i in ret.items:
        info = {'kind': i.kind, 'namespace': i.metadata.namespace, 'name': i.metadata.name, 'ip': i.spec.cluster_ip,
                'ports': i.spec.ports}
        result.append(info)
    return result


def list_pod():
    result = []
    ret = core.list_pod_for_all_namespaces(watch=False)
    for i in ret.items:
        info = {'pod_ip': i.status.pod_ip, 'namespace': i.metadata.namespace, 'name': i.metadata.name}
        result.append(info)
    return result


def list_deploy():
    result = []
    ret = api.list_deployment_for_all_namespaces(watch=False)
    for i in ret.items:
        images = [x.image for x in i.spec.template.spec.containers]
        info = {'namespace': i.metadata.namespace, 'name': i.metadata.name, 'images': images}
        result.append(info)
    return result

2、更新

def upgrade_by_kube(update_image):
    # 傳入參數配置
    name = 'flaskapp-1' 
    namespace = 'default' 

    # read deployment
    body = api.read_namespaced_deployment(name, namespace)
    # 修改鏡像版本為指定
    body.spec.template.spec.containers[0].image = update_image
    try:
        api.replace_namespaced_deployment(name, namespace, body)
        print("\033[0;32m{} 中deployment : {} {}更新完成\033[0m".format(namespace, name, update_image))
    except ApiException as e:
        print("Exception when calling AppsV1Api->replace_namespaced_deployment: %s\n" % e)