如何通过C# Kubernetes Client API获取StatefulSet关联Pod的集群IP

一、判断Pod是否属于指定StatefulSet #

有两种可靠方式：

1. 用StatefulSet标签选择器筛选（推荐，更高效）

StatefulSet的Spec.Selector.MatchLabels定义了它管理的Pod会携带的标签，直接把这个标签选择器传给ListNamespacedPodAsync，让K8s API端帮你过滤目标Pod，不用本地遍历所有Pod：

// 先获取目标StatefulSet
var targetSts = await k8s.AppsV1.ReadNamespacedStatefulSetAsync("your-sts-name", "your-namespace");

// 把标签集合转成K8s API支持的选择器字符串
var labelSelector = string.Join(",", targetSts.Spec.Selector.MatchLabels.Select(kv => $"{kv.Key}={kv.Value}"));

// 筛选关联Pod
var stsPods = await k8s.CoreV1.ListNamespacedPodAsync("your-namespace", labelSelector: labelSelector);

2. 检查Pod的OwnerReferences（更精准）

StatefulSet创建的Pod，其Metadata.OwnerReferences里会包含该StatefulSet的Kind、Name、Uid信息，通过这个可以精准验证归属：

// 提前拿到目标StatefulSet的Uid
var stsUid = targetSts.Metadata.Uid;

// 遍历筛选后的Pod做二次验证（可选，用于标签可能重复的场景）
foreach (var pod in stsPods.Items)
{
    var isOwnedBySts = pod.Metadata.OwnerReferences.Any(or => 
        or.Kind == "StatefulSet" && 
        or.Name == "your-sts-name" && 
        or.Uid == stsUid);
    if (isOwnedBySts)
    {
        // 确认该Pod属于目标StatefulSet
    }
}

二、获取Pod的集群IP地址 #

Pod的集群IP直接存在Status.PodIP属性里，读取即可：

foreach (var pod in stsPods.Items)
{
    var clusterIp = pod.Status.PodIP;
    // 这里可以对IP做后续处理
}

完整示例代码 #

using KubernetesClient;

var config = KubernetesClientConfiguration.BuildDefaultConfig();
using var k8s = new Kubernetes(config);

// 替换成你的StatefulSet名称和命名空间
var stsName = "my-statefulset";
var namespaceName = "default";

try
{
    // 获取目标StatefulSet
    var targetSts = await k8s.AppsV1.ReadNamespacedStatefulSetAsync(stsName, namespaceName);
    
    // 筛选关联Pod
    var labelSelector = string.Join(",", targetSts.Spec.Selector.MatchLabels.Select(kv => $"{kv.Key}={kv.Value}"));
    var stsPods = await k8s.CoreV1.ListNamespacedPodAsync(namespaceName, labelSelector: labelSelector);
    
    // 输出Pod信息
    foreach (var pod in stsPods.Items)
    {
        Console.WriteLine($"Pod名称: {pod.Metadata.Name}, 集群IP: {pod.Status.PodIP}");
    }
}
catch (Exception ex)
{
    Console.WriteLine($"操作失败: {ex.Message}");
}

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