K8s基于标签查询集群资源耗时过长问题排查求助

你的代码耗时长达20秒，核心原因集中在resource.Builder的使用方式和内置逻辑上，具体如下：

• 过多资源类型导致批量请求累加：如果res参数包含all或大量资源类型，resource.Builder会为每个类型单独发起API请求，多次请求的往返耗时累加后就会拖慢整体速度。
• Flatten()触发额外子资源查询：该方法会递归获取所有关联子资源（比如Deployment对应的ReplicaSet、Pod），相当于自动执行了N次额外查询，大幅增加了请求总量。
• resource.Builder的CLI附加开销：这个组件是为kubectl这类命令行工具设计的，内置了格式转换、输出处理等额外逻辑，对于纯数据查询场景来说，这些冗余处理会增加不必要的耗时。

优化步骤 #

1. 精简资源类型列表
   只保留实际需要的资源类型，避免使用all或通配符。比如仅查询Deployment和Pod，不要包含无关资源。

2. 移除Flatten()调用
   如果不需要获取资源的关联子资源，直接删除该方法，减少额外的递归查询。

3. 改用Dynamic Client直接查询
   跳过resource.Builder的封装，用client-go的Dynamic Client直接发起List请求，减少中间处理开销。示例代码：

import (
    "context"
    "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/apimachinery/pkg/runtime/schema"
    "k8s.io/client-go/dynamic"
    "k8s.io/client-go/rest"
)

func getSelectedResources() ([]interface{}, error) {
    // 加载集群配置（根据环境选择InCluster或kubeconfig方式）
    config, err := rest.InClusterConfig()
    if err != nil {
        return nil, err
    }

    dynClient, err := dynamic.NewForConfig(config)
    if err != nil {
        return nil, err
    }

    // 按需定义目标资源类型
    targetResources := []schema.GroupVersionResource{
        {Group: "apps", Version: "v1", Resource: "deployments"},
        {Group: "", Version: "v1", Resource: "pods"},
    }

    var results []interface{}
    for _, gvr := range targetResources {
        resList, err := dynClient.Resource(gvr).Namespace("vrf").List(context.TODO(), v1.ListOptions{
            LabelSelector: "a=b",
        })
        if err != nil {
            continue // 可根据需求选择跳过或终止
        }
        results = append(results, resList.Items...)
    }

    return results, nil
}

4. 简化SelectAllParam逻辑
   直接设置SelectAllParam(false)，避免不必要的条件判断，减少潜在逻辑分支。

优化后，每个资源类型仅发起一次精准的List请求，无额外子资源查询和CLI相关冗余处理，耗时会大幅降低，接近kubectl的查询速度。

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