如何使用fabric8 kubernetes java client读取deployment对应pod内的文件

依赖引入 #

首先确保项目中引入了fabric8 kubernetes client依赖，Maven配置示例如下：

<dependency>
    <groupId>io.fabric8</groupId>
    <artifactId>kubernetes-client</artifactId>
    <version>6.13.1</version>
</dependency>

实现逻辑 #

等价于你给出的kubectl exec命令的实现逻辑如下：

• 根据命名空间、Deployment名称查询目标Deployment资源
• 提取Deployment的标签选择器，筛选出关联的所有就绪状态Pod
• 对选中的Pod执行cat目标文件的命令，读取命令输出即为文件内容

完整代码示例 #

import io.fabric8.kubernetes.api.model.apps.Deployment;
import io.fabric8.kubernetes.api.model.Pod;
import io.fabric8.kubernetes.client.KubernetesClient;
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
import io.fabric8.kubernetes.client.dsl.ExecWatch;
import java.nio.charset.StandardCharsets;
import java.util.List;
import java.util.Map;

public class PodFileReader {
    public static String readFileFromDeploymentPod(String namespace, String deploymentName, String filePath, String containerName) {
        try (KubernetesClient client = new KubernetesClientBuilder().build()) {
            // 查询目标Deployment
            Deployment deployment = client.apps().deployments()
                    .inNamespace(namespace)
                    .withName(deploymentName)
                    .get();
            if (deployment == null) {
                throw new IllegalArgumentException("指定Deployment不存在");
            }
            
            // 筛选Deployment关联的就绪Pod
            Map<String, String> selectorLabels = deployment.getSpec().getSelector().getMatchLabels();
            List<Pod> readyPods = client.pods()
                    .inNamespace(namespace)
                    .withLabels(selectorLabels)
                    .list()
                    .getItems()
                    .stream()
                    .filter(pod -> "Running".equals(pod.getStatus().getPhase())
                            && pod.getStatus().getConditions().stream()
                            .anyMatch(condition -> "Ready".equals(condition.getType()) && "True".equals(condition.getStatus())))
                    .toList();
            if (readyPods.isEmpty()) {
                throw new IllegalStateException("Deployment下没有就绪的Pod");
            }
            Pod targetPod = readyPods.get(0);
            
            // 执行cat命令读取文件
            ExecWatch.ExecWatchBuilder execBuilder = client.pods()
                    .inNamespace(namespace)
                    .withName(targetPod.getMetadata().getName())
                    .exec();
            // 多容器场景指定容器名
            if (containerName != null && !containerName.isBlank()) {
                execBuilder.inContainer(containerName);
            }
            try (ExecWatch execWatch = execBuilder.command("cat", filePath).build()) {
                return new String(execWatch.getOutput().readAllBytes(), StandardCharsets.UTF_8);
            }
        } catch (Exception e) {
            throw new RuntimeException("读取文件失败", e);
        }
    }

    public static void main(String[] args) {
        // 对应你给出的kubectl命令参数
        String content = readFileFromDeploymentPod("logcollection", "otel-collector", "/otel-output/json-out.json", null);
        System.out.println(content);
    }
}

注意事项 #

• 操作使用的Kubernetes身份需要有对应命名空间下的pods/exec、pods/get、deployments/get权限
• 示例默认选取第一个就绪Pod执行操作，如果你需要指定Pod选择规则，可自行调整筛选逻辑
• 如果Pod包含多个容器，需要传入容器名称参数指定要操作的容器

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