k8s Job、Cronjob 的使用

Job负责处理任务，即仅执行一次的任务，它保证批处理任务的一个或多个Pod成功结束。而CronJob则就是在Job上加上了时间调度。

Job

咱们用Job这个资源对象来建立一个任务，咱们定一个Job来执行一个倒计时的任务，定义YAML文件：

apiVersion: batch/v1
kind: Job
metadata:
  name: job-demo
spec:
  template:
    metadata:
      name: job-demo
    spec:
      restartPolicy: Never
      containers:
      - name: counter
        image: busybox
        command:
        - "bin/sh"
        - "-c"
        - "for i in 9 8 7 6 5 4 3 2 1; do echo $i; done"

 

注意Job的RestartPolicy仅支持Never和OnFailure两种，不支持Always，咱们知道Job就至关于来执行一个批处理任务，执行完就结束了，若是支持Always的话是否是就陷入了死循环了？

而后来建立该Job，保存为job-demo.yaml：

$ kubectl create -f ./job.yaml
job "job-demo" created 

而后咱们能够查看当前的Job资源对象：

$ kubectl get jobs 

注意查看咱们的Pod的状态，一样咱们能够经过kubectl logs来查看当前任务的执行结果。

CronJob

CronJob其实就是在Job的基础上加上了时间调度，咱们能够：在给定的时间点运行一个任务，也能够周期性地在给定时间点运行。这个实际上和咱们Linux中的crontab就很是相似了。

一个CronJob对象其实就对应中crontab文件中的一行，它根据配置的时间格式周期性地运行一个Job，格式和crontab也是同样的。

crontab的格式以下：

分 时 日 月 星期 要运行的命令 第1列分钟0～59 第2列小时0～23） 第3列日1～31 第4列月1～12 第5列星期0～7（0和7表示星期天） 第6列要运行的命令

如今，咱们用CronJob来管理咱们上面的Job任务，

apiVersion: batch/v2alpha1
kind: CronJob
metadata:
  name: cronjob-demo
spec:
  schedule: "*/1 * * * *"
  jobTemplate:
    spec:
      template:
        spec:
          restartPolicy: OnFailure
          containers:
          - name: hello
            image: busybox
            args:
            - "bin/sh"
            - "-c"
            - "for i in 9 8 7 6 5 4 3 2 1; do echo $i; done"

 

咱们这里的Kind是CronJob了，要注意的是.spec.schedule字段是必须填写的，用来指定任务运行的周期，格式就和crontab同样，另一个字段是.spec.jobTemplate, 用来指定须要运行的任务，格式固然和Job是一致的。还有一些值得咱们关注的字段.spec.successfulJobsHistoryLimit和.spec.failedJobsHistoryLimit，表示历史限制，是可选的字段。它们指定了能够保留多少完成和失败的Job，默认没有限制，全部成功和失败的Job都会被保留。然而，当运行一个Cron Job时，Job能够很快就堆积不少，因此通常推荐设置这两个字段的值。若是设置限制的值为 0，那么相关类型的Job完成后将不会被保留。

接下来咱们来建立这个cronjob

$ kubectl create -f cronjob-demo.yaml
cronjob "cronjob-demo" created 

固然，也能够用kubectl run来建立一个CronJob：

kubectl run hello --schedule="*/1 * * * *" --restart=OnFailure --image=busybox -- /bin/sh -c "date; echo Hello from the Kubernetes cluster"
$ kubectl get cronjob
NAME      SCHEDULE      SUSPEND   ACTIVE    LAST-SCHEDULE
hello     */1 * * * *   False     0         <none>
$ kubectl get jobs
NAME               DESIRED   SUCCESSFUL   AGE
hello-1202039034   1         1            49s
$ pods=$(kubectl get pods --selector=job-name=hello-1202039034 --output=jsonpath={.items..metadata.name} -a)
$ kubectl logs $pods
Mon Aug 29 21:34:09 UTC 2016
Hello from the Kubernetes cluster
$ kubectl delete cronjob hello
cronjob "hello" deleted

 

一旦再也不须要 Cron Job，简单地可使用 kubectl 命令删除它：

$ kubectl delete cronjob hello
cronjob "hello" deleted 

这将会终止正在建立的 Job。然而，运行中的 Job 将不会被终止，不会删除 Job 或 它们的 Pod。为了清理那些 Job 和 Pod，须要列出该 Cron Job 建立的所有 Job，而后删除它们：

$ kubectl get jobs
NAME               DESIRED   SUCCESSFUL   AGE
hello-1201907962   1         1            11m
hello-1202039034   1         1            8m

　　

[root@k8s-master01 jobs]# kubectl get cronjobs.batch 
NAME           SCHEDULE      SUSPEND   ACTIVE    LAST SCHEDULE   AGE
cronjob-demo   */1 * * * *   False     1         9s              4m

 

$ kubectl delete jobs hello-1201907962 hello-1202039034 ...
job "hello-1201907962" deleted
job "hello-1202039034" deleted

　　

一旦 Job 被删除，由 Job 建立的 Pod 也会被删除。注意，全部由名称为 “hello” 的 Cron Job 建立的 Job 会之前缀字符串 “hello-” 进行命名。若是想要删除当前 Namespace 中的全部 Job，能够经过命令 kubectl delete jobs --all 马上删除它们。