使用 Python 为 Google Kubernetes Engine (GKE) 构建 Kubernetes 客户端

admin数码26/11/2024 09:16:4900

使用 Python 为 Google Kubernetes Engine (GKE) 构建 Kubernetes 客户端-第1张图片-海印网

这篇博文介绍了一种使用 python 为 gke 创建 kubernetes 客户端的有效方法。通过利用 google-cloud-container、google-auth 和 kubernetes 库，无论您的应用程序是在本地运行还是在 google cloud 上运行，您都可以使用相同的代码与 kubernetes api 进行交互。这种灵活性来自于使用应用程序默认凭证（adc）来验证和动态构建 kubernetes api 交互所需的请求，从而无需使用额外的工具或配置文件（如 kubeconfig）。

本地运行时，常见的方法是使用 gcloud 容器集群 get-credentials 命令生成 kubeconfig 文件并使用 kubectl 与 kubernetes api 交互。虽然此工作流程对于本地设置来说是自然且有效的，但在 cloud run 或其他 google cloud 服务等环境中却变得不太实用。

借助 adc，您可以通过动态配置 kubernetes 客户端来简化对 gke 集群的 kubernetes api 的访问。这种方法可确保以一致、高效的方式连接到集群，而无需管理外部配置文件或安装额外工具的开销。

先决条件

1. 使用 google cloud 进行身份验证

如果您在本地运行代码，只需使用以下命令进行身份验证：

gcloud auth application-default login

登录后复制

这将使用您的用户帐户凭据作为应用程序默认凭据（adc）。

立即学习“Python免费学习笔记（深入）”；

如果您在 cloud run 等 google cloud 服务上运行代码，则无需手动处理身份验证。只需确保该服务具有正确配置的服务帐户，并具有访问 gke 集群所需的权限。

2. 收集您的集群详细信息

运行脚本之前，请确保您了解以下详细信息：

google cloud 项目 id：托管 gke 集群的项目的 id。
集群位置：集群所在的区域或可用区（例如 us-central1-a）。
集群名称：您要连接的 kubernetes 集群的名称。

脚本

下面是为 gke 集群设置 kubernetes 客户端的 python 函数。

from google.cloud import container_v1
import google.auth
import google.auth.transport.requests
from kubernetes import client as kubernetes_client
from tempfile import namedtemporaryfile
import base64
import yaml

def get_k8s_client(project_id: str, location: str, cluster_id: str) -> kubernetes_client.corev1api:
    """
    fetches a kubernetes client for the specified gcp project, location, and cluster id.

    args:
        project_id (str): google cloud project id
        location (str): location of the cluster (e.g., "us-central1-a")
        cluster_id (str): name of the kubernetes cluster

    returns:
        kubernetes_client.corev1api: kubernetes corev1 api client
    """

    # retrieve cluster information
    gke_cluster = container_v1.clustermanagerclient().get_cluster(request={
        "name": f"projects/{project_id}/locations/{location}/clusters/{cluster_id}"
    })

    # obtain google authentication credentials
    creds, _ = google.auth.default()
    auth_req = google.auth.transport.requests.request()
    # refresh the token
    creds.refresh(auth_req)

    # initialize the kubernetes client configuration object
    configuration = kubernetes_client.configuration()
    # set the cluster endpoint
    configuration.host = f'https://{gke_cluster.endpoint}'

    # write the cluster ca certificate to a temporary file
    with namedtemporaryfile(delete=false) as ca_cert:
        ca_cert.write(base64.b64decode(gke_cluster.master_auth.cluster_ca_certificate))
        configuration.ssl_ca_cert = ca_cert.name

    # set the authentication token
    configuration.api_key_prefix['authorization'] = 'bearer'
    configuration.api_key['authorization'] = creds.token

    # create and return the kubernetes corev1 api client
    return kubernetes_client.corev1api(kubernetes_client.apiclient(configuration))


def main():
    project_id = "your-project-id"  # google cloud project id
    location = "your-cluster-location"  # cluster region (e.g., "us-central1-a")
    cluster_id = "your-cluster-id"  # cluster name

    # retrieve the kubernetes client
    core_v1_api = get_k8s_client(project_id, location, cluster_id)

    # fetch the kube-system namespace
    namespace = core_v1_api.read_namespace(name="kube-system")

    # output the namespace resource in yaml format
    yaml_output = yaml.dump(namespace.to_dict(), default_flow_style=false)
    print(yaml_output)

if __name__ == "__main__":
    main()

登录后复制

它是如何运作的

1. 连接gke集群

get_k8s_client 函数首先使用 google-cloud-container 库从 gke 获取集群详细信息。该库与 gke 服务交互，允许您检索集群的 api 端点和证书颁发机构 (ca) 等信息。这些详细信息对于配置 kubernetes 客户端至关重要。

gke_cluster = container_v1.clustermanagerclient().get_cluster(request={
    "name": f"projects/{project_id}/locations/{location}/clusters/{cluster_id}"
})

登录后复制

需要注意的是，google-cloud-container 库是为与 gke 作为服务交互而设计的，而不是直接与 kubernetes api 交互。例如，虽然您可以使用此库检索集群信息、升级集群或配置维护策略（类似于使用 gcloud 容器集群命令执行的操作），但您无法使用它直接获取 kubernetes api 客户端。这种区别就是为什么该函数在从 gke 获取必要的集群详细信息后单独构建 kubernetes 客户端。

2. 使用 google cloud 进行身份验证

为了与 gke 和 kubernetes api 交互，该函数使用 google cloud 的应用程序默认凭据 (adc) 进行身份验证。以下是身份验证过程的每个步骤的工作原理：

google.auth.default()

此函数检索代码运行环境的 adc。根据上下文，它可能会返回：

用户帐户凭据（例如，来自本地开发设置中的 gcloud auth 应用程序默认登录）。
服务帐户凭据（例如，在 cloud run 等 google cloud 环境中运行时）。

它还会返回关联的项目 id（如果可用），尽管在本例中仅使用凭据。

google.auth.transport.requests.request()

这将创建一个 http 请求对象，用于处理与身份验证相关的网络请求。它在内部使用 python 的 requests 库，并提供标准化的方法来刷新凭据或请求访问令牌。

creds.refresh(auth_req)

当使用 google.auth.default() 检索 adc 时，凭证对象最初不包含访问令牌（至少在本地环境中）。 fresh() 方法显式获取访问令牌并将其附加到凭证对象，使其能够对 api 请求进行身份验证。

以下代码演示了如何验证此行为：

# obtain google authentication credentials
creds, _ = google.auth.default()
auth_req = google.auth.transport.requests.request()

# inspect credentials before refreshing
print(f"access token (before refresh()): {creds.token}")
print(f"token expiry (before refresh()): {creds.expiry}")

# refresh the token
creds.refresh(auth_req)

# inspect credentials after refreshing
print(f"access token (after): {creds.token}")
print(f"token expiry (after): {creds.expiry}")

登录后复制

示例输出：

access token (before refresh()): none
token expiry (before refresh()): 2024-11-24 06:11:19.640651

access token (after): **********
token expiry (after): 2024-11-24 07:16:06.866467

登录后复制

调用refresh()之前，token属性为none。调用刷新（）后，凭证将填充有效的访问令牌及其到期时间。

3.配置kubernetes客户端

kubernetes 客户端是使用集群的 api 端点、ca 证书的临时文件和刷新的承载令牌进行配置的。这确保客户端可以安全地进行身份验证并与集群通信。

configuration.host = f'https://{gke_cluster.endpoint}'
configuration.api_key['authorization'] = creds.token

登录后复制

ca 证书临时存储并由客户端引用以进行安全 ssl 通信。通过这些设置，kubernetes 客户端已完全配置并准备好与集群交互。

示例输出

这是 kube-system 命名空间的 yaml 输出示例：

api_version: v1
kind: Namespace
metadata:
  annotations: null
  creation_timestamp: 2024-11-24 04:49:48+00:00
  deletion_grace_period_seconds: null
  deletion_timestamp: null
  finalizers: null
  generate_name: null
  generation: null
  labels:
    kubernetes.io/metadata.name: kube-system
  managed_fields:
  - api_version: v1
    fields_type: FieldsV1
    fields_v1:
      f:metadata:
        f:labels:
          .: {}
          f:kubernetes.io/metadata.name: {}
    manager: kube-apiserver
    operation: Update
    subresource: null
    time: 2024-11-24 04:49:48+00:00
  name: kube-system
  namespace: null
  owner_references: null
  resource_version: '15'
  self_link: null
  uid: 01132228-7e86-4b74-8b78-8ceaa8df9913
spec:
  finalizers:
  - kubernetes
status:
  conditions: null
  phase: Active

登录后复制

结论

这种方法强调了使用相同代码与 kubernetes api 交互的可移植性，无论是在本地运行还是在 cloud run 等 google cloud 服务上运行。通过利用应用程序默认凭证 (adc)，我们演示了一种灵活的方法来动态生成 kubernetes api 客户端，而无需依赖预先生成的配置文件或外部工具。这使得构建能够无缝适应不同环境的应用程序变得容易，从而简化了开发和部署工作流程。

以上就是使用 Python 为 Google Kubernetes Engine (GKE) 构建 Kubernetes 客户端的详细内容，更多请关注其它相关文章！

Tags：集群客户端