如何使用 Java API 在 Kubernetes 中创建作业

Question

能够使用 CLI 在 Kubernetes 集群中创建作业 ( https://kubernetesbyexample.com/jobs/ )

有没有办法使用 Java API 在集群内创建作业？

Answer 1

您可以使用 Kubernetes Java Client 创建任何对象，例如 Job。从这里的例子参考

\n

/*\n * Creates a simple run to complete job that computes \xcf\x80 to 2000 places and prints it out.\n */\npublic class JobExample {\n    private static final Logger logger = LoggerFactory.getLogger(JobExample.class);\n\n    public static void main(String[] args) {\n        final ConfigBuilder configBuilder = new ConfigBuilder();\n        if (args.length > 0) {\n          configBuilder.withMasterUrl(args[0]);\n        }\n        try (KubernetesClient client = new DefaultKubernetesClient(configBuilder.build())) {\n          final String namespace = "default";\n          final Job job = new JobBuilder()\n            .withApiVersion("batch/v1")\n            .withNewMetadata()\n            .withName("pi")\n            .withLabels(Collections.singletonMap("label1", "maximum-length-of-63-characters"))\n            .withAnnotations(Collections.singletonMap("annotation1", "some-very-long-annotation"))\n            .endMetadata()\n            .withNewSpec()\n            .withNewTemplate()\n            .withNewSpec()\n            .addNewContainer()\n            .withName("pi")\n            .withImage("perl")\n            .withArgs("perl", "-Mbignum=bpi", "-wle", "print bpi(2000)")\n            .endContainer()\n            .withRestartPolicy("Never")\n            .endSpec()\n            .endTemplate()\n            .endSpec()\n            .build();\n\n          logger.info("Creating job pi.");\n          client.batch().jobs().inNamespace(namespace).createOrReplace(job);\n\n          // Get All pods created by the job\n          PodList podList = client.pods().inNamespace(namespace).withLabel("job-name", job.getMetadata().getName()).list();\n          // Wait for pod to complete\n          client.pods().inNamespace(namespace).withName(podList.getItems().get(0).getMetadata().getName())\n            .waitUntilCondition(pod -> pod.getStatus().getPhase().equals("Succeeded"), 1, TimeUnit.MINUTES);\n\n          // Print Job\'s log\n          String joblog = client.batch().jobs().inNamespace(namespace).withName("pi").getLog();\n          logger.info(joblog);\n\n        } catch (KubernetesClientException e) {\n            logger.error("Unable to create job", e);\n        } catch (InterruptedException interruptedException) {\n          logger.warn("Thread interrupted!");\n          Thread.currentThread().interrupt();\n        }\n    }\n}\n

\n