如何启动Pod并为其输入流提供数据

echo "echo foo" | kubectl run -i busybox --image=busybox --restart=Never --command -- sh

cat my_context.tar.gz | kubectl run -i kaniko-builder \
  --image=gcr.io/kaniko-project/executor:latest \
  --restart=Never \
  --command -- /kaniko/executor \
  --context tar://stdin \
  --destination my-registry/my-image:latest \
  --dockerfile Dockerfile

import io.fabric8.kubernetes.api.model.Pod;
import io.fabric8.kubernetes.api.model.PodBuilder;
import io.fabric8.kubernetes.client.KubernetesClient;
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
import io.fabric8.kubernetes.client.dsl.ExecListener;
import io.fabric8.kubernetes.client.dsl.PodResource;
import okhttp3.Response;

import java.io.ByteArrayInputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

public class PodStdinFeeder {

    public static void main(String[] args) throws Exception {
        try (KubernetesClient client = new KubernetesClientBuilder().build()) {
            String podName = "kaniko-builder-programmatic";
            String namespace = "default"; // 或你的目标命名空间

            // 1. 创建Pod定义
            Pod pod = new PodBuilder()
                    .withNewMetadata().withName(podName).endMetadata()
                    .withNewSpec()
                    .addNewContainer()
                    .withName("kaniko")
                    .withImage("gcr.io/kaniko-project/executor:latest")
                    .withCommand("/kaniko/executor")
                    .withArgs("--context", "tar://stdin", "--destination", "my-registry/my-image:latest")
                    .endContainer()
                    .withRestartPolicy("Never") // 确保任务完成后Pod终止
                    .endSpec()
                    .build();

            // 2. 创建Pod
            System.out.println("Creating Pod: " + podName);
            Pod createdPod = client.pods().inNamespace(namespace).resource(pod).create();
            System.out.println("Pod created. Waiting for it to run...");

            // 等待Pod进入Running状态
            client.pods().inNamespace(namespace).withName(podName)
                    .waitUntilReady(5, TimeUnit.MINUTES);
            System.out.println("Pod is running.");

            // 假设这是你的 tar.gz 数据流
            // 实际应用中，这里会是 FileInputStream 或其他二进制数据源
            String dummyTarGzContent = "This is a dummy tar.gz content for demonstration.";
            InputStream dataToFeed = new ByteArrayInputStream(dummyTarGzContent.getBytes(StandardCharsets.UTF_8));

            CountDownLatch latch = new CountDownLatch(1);

            // 3. 建立Stdin连接并写入数据
            System.out.println("Attaching to Pod stdin...");
            client.pods().inNamespace(namespace).withName(podName)
                    .redirectingInput() // 启用stdin重定向
                    .exec("sh", "-c", "/kaniko/executor --context tar://stdin --destination my-registry/my-image:latest") // 或者直接执行容器的命令
                    .withTTY() // 如果需要交互式终端
                    .withStdin(dataToFeed) // 提供要写入的输入流
                    .withListener(new ExecListener() {
                        @Override
                        public void onOpen(Response response) {
                            System.out.println("Stdin connection opened.");
                        }

                        @Override
                        public void onFailure(Throwable t, Response response) {
                            System.err.println("Stdin connection failed: " + t.getMessage());
                            latch.countDown();
                        }

                        @Override
                        public void onClose(int code, String reason) {
                            System.out.println("Stdin connection closed. Code: " + code + ", Reason: " + reason);
                            latch.countDown();
                        }
                    })
                    .join(); // 阻塞直到连接关闭

            latch.await(10, TimeUnit.MINUTES); // 等待操作完成

            System.out.println("Stdin operation completed. Pod should be processing data.");

            // 4. 清理Pod (可选，取决于你的策略)
            // client.pods().inNamespace(namespace).withName(podName).delete();
            // System.out.println("Pod deleted.");

        } catch (Exception e) {
            System.err.println("An error occurred: " + e.getMessage());
            e.printStackTrace();
        }
    }
}