如何获取集群中带OwnerRef层级关系的所有Pods？

一、基于client-go的手动实现 #

你可以直接借助现有client-go客户端，通过递归查询Pod的OwnerReferences字段，逐层向上追溯所属的Deployment、StatefulSet甚至自定义Kind控制器，最终构建完整的层级关系。

核心实现步骤 #

1. 获取集群内所有Pod（即你当前使用的代码）
2. 对每个Pod，遍历其OwnerReferences，调用K8s API查询对应的owner资源
3. 递归重复步骤2，直到目标资源没有更高层级的OwnerReference为止

代码示例 #

首先定义结构体存储资源节点信息：

type ResourceNode struct {
    Name        string
    Kind        string
    APIVersion  string
    Children    []*ResourceNode
}

然后实现递归获取Owner链的函数：

import (
    "context"
    "strings"
    "fmt"

    "k8s.io/apimachinery/pkg/runtime"
    "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/apimachinery/pkg/runtime/schema"
    "k8s.io/client-go/kubernetes"
)

func getOwnerChain(client kubernetes.Interface, obj v1.Object) ([]*ResourceNode, error) {
    var chain []*ResourceNode
    for _, ref := range obj.GetOwnerReferences() {
        // 解析OwnerReference的API组和版本
        gv, err := schema.ParseGroupVersion(ref.APIVersion)
        if err != nil {
            return nil, err
        }
        // 通过RESTClient查询对应的owner资源
        result, err := client.RESTClient().Get().
            Namespace(obj.GetNamespace()).
            Resource(gv.WithKind(ref.Kind).Resource).
            Name(ref.Name).
            Do(context.Background()).
            Get()
        if err != nil {
            return nil, err
        }
        // 将返回结果转换为metav1.Object
        ownerObj := &v1.PartialObjectMetadata{}
        if err := runtime.DefaultUnstructuredConverter.FromUnstructured(result.UnstructuredContent(), ownerObj); err != nil {
            return nil, err
        }
        // 构建当前资源节点
        node := &ResourceNode{
            Name:       ref.Name,
            Kind:       ref.Kind,
            APIVersion: ref.APIVersion,
        }
        // 递归获取更高层级的Owner链
        childChain, err := getOwnerChain(client, ownerObj)
        if err != nil {
            return nil, err
        }
        node.Children = childChain
        chain = append(chain, node)
    }
    return chain, nil
}

最后遍历Pod并打印层级关系：

func main() {
    // 假设已完成client初始化
    client, err := kubernetes.NewForConfig(...)
    if err != nil {
        panic(err)
    }

    // 获取所有Pod
    pods, err := client.CoreV1().Pods("").List(context.Background(), v1.ListOptions{})
    if err != nil {
        panic(err)
    }

    // 遍历每个Pod，打印Owner层级
    for _, pod := range pods.Items {
        fmt.Printf("Pod: %s/%s\n", pod.Namespace, pod.Name)
        chain, err := getOwnerChain(client, &pod)
        if err != nil {
            fmt.Printf("获取Owner链失败: %v\n", err)
            continue
        }
        printChain(chain, 1)
    }
}

// 辅助打印函数，用缩进展示层级
func printChain(chain []*ResourceNode, indent int) {
    for _, node := range chain {
        fmt.Printf("%s%s (%s/%s)\n", strings.Repeat("  ", indent), node.Name, node.APIVersion, node.Kind)
        printChain(node.Children, indent+1)
    }
}

二、现成工具/库选项 #

• 命令行层面：使用kubectl tree插件，执行kubectl tree pod <pod-name>即可输出完整层级关系，支持自定义CRD资源
• 代码层面：可参考K8s官方k8s.io/kubernetes/pkg/printers/internalversion包中的TreePrinter实现，该逻辑已封装层级追溯核心逻辑，可直接复用或修改

注意事项 #

• 确保客户端拥有足够RBAC权限，能访问所有需查询的资源（包括自定义CRD）
• 需添加错误处理，比如处理Owner资源已被删除的情况
• 可添加循环引用检测，避免无限递归（K8s原生OwnerReference一般无循环，但自定义资源可能存在）

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