如何通过Go获取多GCP项目中GKE集群的Deployment信息？

1. GCP容器API（container/apiv1）能否获取Deployment信息？ #

不行。GCP容器API（即GKE管理API）仅负责集群的生命周期管理，比如创建/删除集群、获取集群配置、节点池信息等运维层面的操作，完全不涉及Kubernetes集群内部的资源（如Deployment、Pod、Service）。所以无法通过cloud.google.com/go/container/apiv1获取Deployment的标签数据，必须使用Kubernetes官方Go客户端client-go。

2. 如何用client-go结合GOOGLE_APPLICATION_CREDENTIALS访问GKE集群？ #

不需要依赖本地.kubeconfig文件，直接通过GOOGLE_APPLICATION_CREDENTIALS指向的服务账号密钥生成Kubernetes客户端配置即可，核心步骤及代码示例如下：

核心流程 #

• 用container/apiv1获取目标集群的端点地址和CA证书
• 通过GCP服务账号生成访问GKE的Bearer Token
• 将上述信息组装为client-go所需的rest.Config，创建客户端访问Deployment资源

示例代码 #

package main

import (
	"context"
	"fmt"
	"os"

	"cloud.google.com/go/container/apiv1"
	containerpb "google.golang.org/genproto/googleapis/container/v1"
	"golang.org/x/oauth2/google"
	appsv1 "k8s.io/api/apps/v1"
	"k8s.io/apimachinery/pkg/api/errors"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/rest"
)

// 获取GKE集群的client-go配置
func getGKEClusterConfig(ctx context.Context, projectID, zone, clusterID string) (*rest.Config, error) {
	containerClient, err := container.NewClusterManagerClient(ctx)
	if err != nil {
		return nil, err
	}
	defer containerClient.Close()

	// 获取集群基础信息
	clusterResp, err := containerClient.GetCluster(ctx, &containerpb.GetClusterRequest{
		ProjectId: projectID,
		Zone:      zone,
		ClusterId: clusterID,
	})
	if err != nil {
		return nil, err
	}

	// 用GOOGLE_APPLICATION_CREDENTIALS生成Token
	creds, err := google.FindDefaultCredentials(ctx, "https://www.googleapis.com/auth/cloud-platform")
	if err != nil {
		return nil, err
	}
	token, err := creds.TokenSource.Token()
	if err != nil {
		return nil, err
	}

	// 组装rest.Config
	return &rest.Config{
		Host:        fmt.Sprintf("https://%s", clusterResp.Endpoint),
		BearerToken: token.AccessToken,
		TLSClientConfig: rest.TLSClientConfig{
			CAData: clusterResp.MasterAuth.ClusterCaCertificate,
		},
	}, nil
}

// 获取指定Deployment的标签
func getDeploymentLabels(ctx context.Context, config *rest.Config, namespace, deployName string) (map[string]string, error) {
	clientset, err := kubernetes.NewForConfig(config)
	if err != nil {
		return nil, err
	}

	deploy, err := clientset.AppsV1().Deployments(namespace).Get(ctx, deployName, metav1.GetOptions{})
	if err != nil {
		if errors.IsNotFound(err) {
			return nil, fmt.Errorf("deployment %s not found in namespace %s", deployName, namespace)
		}
		return nil, err
	}

	return deploy.ObjectMeta.Labels, nil
}

func main() {
	ctx := context.Background()
	// 替换为你的实际参数
	projectID := "your-gcp-project-id"
	zone := "us-central1-a"
	clusterID := "your-gke-cluster-name"
	namespace := "default"
	deployName := "target-deployment"

	// 获取集群配置
	config, err := getGKEClusterConfig(ctx, projectID, zone, clusterID)
	if err != nil {
		fmt.Printf("Failed to get cluster config: %v\n", err)
		os.Exit(1)
	}

	// 获取Deployment标签
	labels, err := getDeploymentLabels(ctx, config, namespace, deployName)
	if err != nil {
		fmt.Printf("Failed to get deployment labels: %v\n", err)
		os.Exit(1)
	}

	fmt.Println("Deployment labels:")
	for k, v := range labels {
		fmt.Printf("  %s: %s\n", k, v)
	}
}

注意事项 #

• 确保服务账号拥有roles/container.developer（或更高权限），才能访问GKE集群内部资源
• Bearer Token默认有效期1小时，长期运行的程序需要定时调用creds.TokenSource.Token()刷新Token
• 遍历多集群时，只需循环调用上述两个核心函数即可

内容的提问来源于stack exchange，提问作者RobTheRobot16