Job

容器按照持续运行的时间可分为两类：服务类容器和工作类容器。

服务类容器通常持续提供服务，需要一直运行，比如 http server，daemon 等。工作类容器则是一次性任务，比如批处理程序，完成后容器就退出。

Kubernetes 的 Deployment、ReplicaSet 和 DaemonSet 都用于管理服务类容器；对于工作类容器，我们用 Job。

第一步：

先看一个简单的 Job 配置文件 myjob.yml：

[root@ken-node1 ~]# cat job.yml

apiVersion:  batch/v1

kind: Job

metadata:

  name: job

spec:

  template:

     spec:

        containers:

            - name: job

              image: busybox

              command: ["echo","hello world"]

        restartPolicy: Never

① batch/v1 是当前 Job 的 apiVersion。

② 指明当前资源的类型为 Job。

③ restartPolicy 指定什么情况下需要重启容器。对于 Job，只能设置为 Never 或者 OnFailure。对于其他 controller（比如 Deployment）可以设置为 Always 。

第二步：通过 kubectl apply -f myjob.yml 启动 Job。

[root@ken ~]# kubectl apply -f myjob.yml

job.batch/job created

第三步：查看job的状态

[root@ken ~]# kubectl get job

NAME    COMPLETIONS   DURATION   AGE

job   1/1           4s         40s

第四步：查看pod的状态

[root@ken ~]# kubectl get pod

NAME                                READY   STATUS      RESTARTS   AGE

job-8hczg                         0/1     Completed   0          83s

显示completed已经完成

第五步：查看pod的标准输出

[root@ken ~]# kubectl logs myjob-8hczg

hello world

job失败的情况

讨论了job执行成功的情况，如果失败了会怎么样呢？

第一步：修改 myjob.yml，故意引入一个错误：

apiVersion:  batch/v1

kind: Job

metadata:

  name: job

spec:

  template:

     spec:

        containers:

            - name: job

              image: busybox

              command: ["echosssss","hello world"]

        restartPolicy: Never

第二步：删除之前的job

[root@ken ~]# kubectl delete -f job.yml

job.batch "job" deleted

[root@ken ~]# kubectl get job

No resources found.

第三步：运行新的job并查看状态

[root@ken ~]# kubectl apply -f job.yml

job.batch/job created

[root@ken ~]# kubectl get job

NAME    COMPLETIONS   DURATION   AGE

myjob   0/1           6s         6s

可以发现完成为0

第四步：查看pod状态

[root@ken ~]# kubectl get pod

NAME                                READY   STATUS               RESTARTS   AGE

myjob-hc6ld                         0/1     ContainerCannotRun   0          64s

myjob-hfblk                         0/1     ContainerCannotRun   0          60s

myjob-t9f6v                         0/1     ContainerCreating    0          11s

myjob-v2g7s                         0/1     ContainerCannotRun   0          31s

可以看到有多个 Pod，状态均不正常。kubectl describe pod 查看某个 Pod 的启动日志：

第五步：查看pod的启动日志

[root@ken-node1 ~]# kubectl describe pods job-r9lrl

Name:               job-r9lrl

Namespace:          default

Priority:           0

PriorityClassName:  <none>

Node:               ken-node3/192.168.163.134

Start Time:         Sat, 03 Aug 2019 01:37:26 +0800

Labels:             controller-uid=15d81b0a-b509-11e9-a9b7-000c29e2b20a

                    job-name=job

Annotations:        <none>

Status:             Failed

IP:                 10.244.2.41

Controlled By:      Job/job

Containers:

  job:

    Container ID:  docker://4d4a0cf1698ba36266c8b59b21714a8547ec28a46e7e73ad1f0ce939cb3befc5

    Image:         busybox

    Image ID:      docker-pullable://busybox@sha256:9f1003c480699be56815db0f8146ad2e22efea85129b5b5983d0e0fb52d9ab70

    Port:          <none>

    Host Port:     <none>

    Command:

      echosssss

      hello world

    State:          Terminated

      Reason:       ContainerCannotRun

      Message:      OCI runtime create failed: container_linux.go:345: starting container process caused "exec: \"echosssss\": executable file not found in $PATH": unknown

      Exit Code:    127

      Started:      Sat, 03 Aug 2019 01:37:40 +0800

      Finished:     Sat, 03 Aug 2019 01:37:40 +0800

    Ready:          False

    Restart Count:  0

    Environment:    <none>

    Mounts:

      /var/run/secrets/kubernetes.io/serviceaccount from default-token-wsrwt (ro)

Conditions:

  Type              Status

  Initialized       True

  Ready             False

  ContainersReady   False

  PodScheduled      True

Volumes:

  default-token-wsrwt:

    Type:        Secret (a volume populated by a Secret)

    SecretName:  default-token-wsrwt

    Optional:    false

QoS Class:       BestEffort

Node-Selectors:  <none>

Tolerations:     node.kubernetes.io/not-ready:NoExecute for 300s

                 node.kubernetes.io/unreachable:NoExecute for 300s

Events:

  Type     Reason     Age        From                Message

  ----     ------     ----       ----                -------

  Normal   Scheduled  60s        default-scheduler   Successfully assigned default/job-r9lrl to ken-node3

  Normal   Pulling    <invalid>  kubelet, ken-node3  Pulling image "busybox"

  Normal   Pulled     <invalid>  kubelet, ken-node3  Successfully pulled image "busybox"

  Normal   Created    <invalid>  kubelet, ken-node3  Created container job

  Warning  Failed     <invalid>  kubelet, ken-node3  Error: failed to start container "job": Error response from daemon: OCI runtime create failed: container_linux.go:345: starting container process caused "exec: \"echosssss\": executable file not found in $PATH": unknown
 

日志显示没有可执行程序，符合我们的预期。

下面解释一个现象：为什么 kubectl get pod 会看到这么多个失败的 Pod？

原因是：当第一个 Pod 启动时，容器失败退出，根据 restartPolicy: Never，此失败容器不会被重启，但 Job DESIRED 的 Pod 是 1，目前 SUCCESSFUL 为 0，不满足，所以 Job controller 会启动新的 Pod，直到 SUCCESSFUL 为 1。对于我们这个例子，SUCCESSFUL 永远也到不了 1，所以 Job controller 会一直创建新的 Pod。为了终止这个行为，只能删除 Job。

[root@ken ~]# kubectl delete -f myjob.yml

job.batch "myjob" deleted

[root@ken ~]# kubectl get pod

NAME                                READY   STATUS    RESTARTS   AGE

如果将 restartPolicy 设置为 OnFailure 会怎么样？下面我们实践一下，修改 myjob.yml 后重新启动。

[root@ken ~]# kubectl apply -f myjob.yml

job.batch/myjob created

[root@ken ~]# kubectl get job

NAME    COMPLETIONS   DURATION   AGE

完成依然为0

再来查看一下pod的状态

[root@ken ~]# kubectl get pod

NAME          READY   STATUS             RESTARTS   AGE

myjob-5tbxw   0/1     CrashLoopBackOff   2          67s

这里只有一个 Pod，不过 RESTARTS 为 3，而且不断增加，说明 OnFailure 生效，容器失败后会自动重启。

定时执行job

Linux 中有 cron 程序定时执行任务，Kubernetes 的 CronJob 提供了类似的功能，可以定时执行 Job。

第一步：CronJob 配置文件示例如下：

 
[root@ken ~]# cat myjob1.yml

apiVersion: batch/v1beta1

kind: CronJob

metadata:

  name: hello

spec:

  schedule: "*/1 * * * *"

  jobTemplate:

    spec:

      template:

         spec:

           containers:

             - name: hello

               image: busybox

               command: ["echo","hello k8s job!"]

           restartPolicy: OnFailure
 

① batch/v1beta1 是当前 CronJob 的 apiVersion。

② 指明当前资源的类型为 CronJob。

③ schedule 指定什么时候运行 Job，其格式与 Linux cron 一致。这里 */1 * * * * 的含义是每一分钟启动一次。

④ jobTemplate 定义 Job 的模板，格式与前面 Job 一致。

第二步：接下来通过 kubectl apply 创建 CronJob。

[root@ken ~]# kubectl apply -f myjob1.yml

cronjob.batch/hello created

第三步：查看crontab的状态

[root@ken ~]# kubectl get cronjob

NAME    SCHEDULE      SUSPEND   ACTIVE   LAST SCHEDULE   AGE

hello   */1 * * * *   False     1        22s             3m12s

第四步：等待几分钟查看jobs的执行情况

[root@ken ~]# kubectl get job

NAME               COMPLETIONS   DURATION   AGE

hello-1548766140   1/1           5s         2m24s

hello-1548766200   1/1           18s        83s

hello-1548766260   1/1           4s         23s

可以看到每隔一分钟就会启动一个 Job。

过段时间查看pod

第五步：执行 kubectl logs 可查看某个 Job 的pod运行日志：

[root@ken ~]# kubectl logs hello-1548766260-6s8lp

hello k8s job!

查看pod会遗留很多已经完成的pod，只需要删除即可

kubectl delete -f myjob1.yml

最新文章

  1. django文件批量上传-简写版
  2. sap后台作业管理/sap打印管理
  3. linux初级，连网
  4. 系统补丁更新导致MVC3.0.0升级到3.0.1的问题解决
  5. html、css杂记
  6. 使用Visual Studio 2013 调试 MASM 汇编程序！
  7. [cocos2d] 谁摸了我一下----触摸事件处理
  8. C# 线程池异步调用
  9. [置顶] java得到前一个月的年月日时分秒
  10. SQL Server 中函数的理解总结
  11. 从蓝光到4K，腾讯视频高码率下载背后的技术
  12. CCF系列之最大的矩形(201312-3)
  13. 我的BO之强类型
  14. React（八）样式及CSS模块化
  15. 【论文速读】Pan He_ICCV2017_Single Shot Text Detector With Regional Attention
  16. selenium-xpath练习
  17. Taro button点击切换选中状态
  18. Ubuntu下安装LNMP
  19. hdu 1588 求f(b) +f(k+b) +f(2k+b) +f((n-1)k +b) 之和 （矩阵快速幂）
  20. ajax解决跨域

热门文章

  1. 用过 mongodb 吧， 这三个大坑踩过吗？
  2. eric4 中pyqt 字符串 输入 获取
  3. topic相关问题
  4. 通俗易懂的 Java 位操作运算讲解
  5. Mysql Lost connection to MySQL server at ‘reading initial communication packet&#39;, system error: 0
  6. Jmeter 常用函数（6）- 详解 __P
  7. 6.ssh免密码登录原理图
  8. HDFS概述和Shell操作
  9. 在Unity中检测死循环和卡死
  10. 从零开始的SpringBoot项目 ( 五 ) 整合 Swagger 实现在线API文档的功能