创建一个 Java api 将手动触发 Kubernetes 已创建的作业

Question

我已经运行在 Kubernates 找到一份工作，计划工作 4 小时。但是我需要写一个 Java API 这样每当我想运行这个工作时我只需要调用这个 API 并且它运行就是工作.

请帮忙解决这个需求。

Answer 1

有两种方法可以运行 POD 中的应用程序为您创建 JOB。
要么你写 java API，当你到达终点时，它就会工作。

对于创建，您可以使用 Java Kubernetes 客户端库。

package io.fabric8.kubernetes.examples;

import io.fabric8.kubernetes.api.model.PodList;
import io.fabric8.kubernetes.api.model.batch.v1.Job;
import io.fabric8.kubernetes.api.model.batch.v1.JobBuilder;
import io.fabric8.kubernetes.client.ConfigBuilder;
import io.fabric8.kubernetes.client.DefaultKubernetesClient;
import io.fabric8.kubernetes.client.KubernetesClient;
import io.fabric8.kubernetes.client.KubernetesClientException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Collections;
import java.util.concurrent.TimeUnit;

/*
 * Creates a simple run to complete job that computes π to 2000 places and prints it out.
 */
public class JobExample {
    private static final Logger logger = LoggerFactory.getLogger(JobExample.class);

    public static void main(String[] args) {
        final ConfigBuilder configBuilder = new ConfigBuilder();
        if (args.length > 0) {
          configBuilder.withMasterUrl(args[0]);
        }
        try (KubernetesClient client = new DefaultKubernetesClient(configBuilder.build())) {
          final String namespace = "default";
          final Job job = new JobBuilder()
            .withApiVersion("batch/v1")
            .withNewMetadata()
            .withName("pi")
            .withLabels(Collections.singletonMap("label1", "maximum-length-of-63-characters"))
            .withAnnotations(Collections.singletonMap("annotation1", "some-very-long-annotation"))
            .endMetadata()
            .withNewSpec()
            .withNewTemplate()
            .withNewSpec()
            .addNewContainer()
            .withName("pi")
            .withImage("perl")
            .withArgs("perl", "-Mbignum=bpi", "-wle", "print bpi(2000)")
            .endContainer()
            .withRestartPolicy("Never")
            .endSpec()
            .endTemplate()
            .endSpec()
            .build();

          logger.info("Creating job pi.");
          client.batch().v1().jobs().inNamespace(namespace).createOrReplace(job);

          // Get All pods created by the job
          PodList podList = client.pods().inNamespace(namespace).withLabel("job-name", job.getMetadata().getName()).list();
          // Wait for pod to complete
          client.pods().inNamespace(namespace).withName(podList.getItems().get(0).getMetadata().getName())
            .waitUntilCondition(pod -> pod.getStatus().getPhase().equals("Succeeded"), 1, TimeUnit.MINUTES);

          // Print Job's log
          String joblog = client.batch().v1().jobs().inNamespace(namespace).withName("pi").getLog();
          logger.info(joblog);

        } catch (KubernetesClientException e) {
            logger.error("Unable to create job", e);
        }
    }
}

选项：2

你也可以应用YAML文件

ApiClient client = ClientBuilder.cluster().build(); //create in-cluster client
Configuration.setDefaultApiClient(client);
BatchV1Api api = new BatchV1Api(client);

V1Job job = new V1Job();
job = (V1Job) Yaml.load(new File("<YAML file path>.yaml")); //apply static yaml file
    
ApiResponse<V1Job> response = api.createNamespacedJobWithHttpInfo("default", job, "true", null, null);

创建一个 Java api 将手动触发 Kubernetes 已创建的作业

create an Java api that will manually trigger Kubernetes already created jobs

java

api

spring-boot

kubernetes

kubectl