--- title: 使用 CronJob 运行自动化任务 content_type: task weight: 10 min-kubernetes-server-version: v1.21 --- 在Kubernetes v1.21 版本中,CronJob 被提升为通用版本。如果你使用的是旧版本的 Kubernetes,请参考你正在使用的 Kubernetes 版本的文档,这样你就能看到准确的信息。旧的 Kubernetes 版本不支持`batch/v1` CronJob API。 你可以利用 [CronJobs](/zh/docs/concepts/workloads/controllers/cron-jobs) 执行基于时间调度的任务。这些自动化任务和 Linux 或者 Unix 系统的 [Cron](https://en.wikipedia.org/wiki/Cron) 任务类似。 CronJobs 在创建周期性以及重复性的任务时很有帮助,例如执行备份操作或者发送邮件。CronJobs 也可以在特定时间调度单个任务,例如你想调度低活跃周期的任务。 CronJobs 有一些限制和特点。 例如,在特定状况下,同一个 CronJob 可以创建多个任务。 因此,任务应该是幂等的。 查看更多限制,请参考 [CronJobs](/zh/docs/concepts/workloads/controllers/cron-jobs)。 ## {{% heading "prerequisites" %}} * {{< include "task-tutorial-prereqs.md" >}} {{< version-check >}} ## 创建 CronJob CronJob 需要一个配置文件。 本例中 CronJob 的`.spec` 配置文件每分钟打印出当前时间和一个问好信息: {{< codenew file="application/job/cronjob.yaml" >}} 想要运行示例的 CronJob,可以下载示例文件并执行命令: ```shell kubectl create -f https://k8s.io/examples/application/job/cronjob.yaml ``` ``` cronjob.batch/hello created ``` 创建好 CronJob 后,使用下面的命令来获取其状态: ```shell kubectl get cronjob hello ``` 输出类似于: ``` NAME SCHEDULE SUSPEND ACTIVE LAST SCHEDULE AGE hello */1 * * * * False 0 50s 75s ``` 就像你从命令返回结果看到的那样,CronJob 还没有调度或执行任何任务。大约需要一分钟任务才能创建好。 ```shell kubectl get jobs --watch ``` ``` NAME COMPLETIONS DURATION AGE hello-4111706356 0/1 0s hello-4111706356 0/1 0s 0s hello-4111706356 1/1 5s 5s ``` 现在你已经看到了一个运行中的任务被 “hello” CronJob 调度。 你可以停止监视这个任务,然后再次查看 CronJob 就能看到它调度任务: ```shell kubectl get cronjob hello ``` 输出类似于: ``` NAME SCHEDULE SUSPEND ACTIVE LAST SCHEDULE AGE hello */1 * * * * False 0 50s 75s ``` 你应该能看到 “hello” CronJob 在 `LAST-SCHEDULE` 声明的时间点成功的调度了一次任务。 有 0 个活跃的任务意味着任务执行完毕或者执行失败。 现在,找到最后一次调度任务创建的 Pod 并查看一个 Pod 的标准输出。请注意任务名称和 Pod 名称是不同的。 {{< note >}} Job 名称和 Pod 名称不同。 {{< /note >}} ```shell # 在你的系统上将 "hello-4111706356" 替换为 Job 名称 pods=$(kubectl get pods --selector=job-name=hello-4111706356 --output=jsonpath={.items..metadata.name}) ``` 查看 Pod 日志: ```shell kubectl logs $pods ``` ``` Fri Feb 22 11:02:09 UTC 2019 Hello from the Kubernetes cluster ``` ## 删除 CronJob 当你不再需要 CronJob 时,可以用 `kubectl delete cronjob ` 删掉它: ```shell kubectl delete cronjob hello ``` 删除 CronJob 会清除它创建的所有任务和 Pod,并阻止它创建额外的任务。你可以查阅 [垃圾收集](/zh/docs/concepts/workloads/controllers/garbage-collection/)。 ## 编写 CronJob 声明信息 像 Kubernetes 的其他配置一样,CronJob 需要 `apiVersion`、`kind`、和 `metadata` 域。 配置文件的一般信息,请参考 [部署应用](/zh/docs/tasks/run-application/run-stateless-application-deployment/) 和 [使用 kubectl 管理资源](/zh/docs/concepts/overview/working-with-objects/object-management/). CronJob 配置也需要包括 [`.spec`](https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status). {{< note >}} 对 CronJob 的所有改动,特别是它的 `.spec`,只会影响将来的运行实例。 {{< /note >}} ### 时间安排 `.spec.schedule` 是 `.spec` 需要的域。它使用了 [Cron](https://en.wikipedia.org/wiki/Cron) 格式串,例如 `0 * * * *` or `@hourly` ,作为它的任务被创建和执行的调度时间。 该格式也包含了扩展的 "Vixie cron" 步长值。 [FreeBSD 手册](https://www.freebsd.org/cgi/man.cgi?crontab%285%29)中解释如下: > 步长可被用于范围组合。范围后面带有 `/<数字>` 可以声明范围内的步幅数值。 > 例如,`0-23/2` 可被用在小时域来声明命令在其他数值的小时数执行 > ( V7 标准中对应的方法是`0,2,4,6,8,10,12,14,16,18,20,22`)。 > 步长也可以放在通配符后面,因此如果你想表达 "每两小时",就用 `*/2` 。 {{< note >}} 调度中的问号 (`?`) 和星号 `*` 含义相同,表示给定域的任何可用值。 {{< /note >}} ### 任务模版 `.spec.jobTemplate`是任务的模版,它是必须的。它和 [Job](/zh/docs/concepts/workloads/controllers/job/)的语法完全一样, 除了它是嵌套的没有 `apiVersion` 和 `kind`。 编写任务的 `.spec` ,请参考 [编写 Job 的Spec](/zh/docs/concepts/workloads/controllers/job/#writing-a-job-spec)。 ### 开始的最后期限 {#starting-deadline} `.spec.startingDeadlineSeconds` 域是可选的。 它表示任务如果由于某种原因错过了调度时间,开始该任务的截止时间的秒数。过了截止时间,CronJob 就不会开始任务。 不满足这种最后期限的任务会被统计为失败任务。如果该域没有声明,那任务就没有最后期限。 如果`.spec.startingDeadlineSeconds`字段被设置(非空),CronJob 控制器会计算从预期创建 Job 到当前时间的时间差。 如果时间差大于该限制,则跳过此次执行。 例如,如果将其设置为 `200`,则 Job 控制器允许在实际调度之后最多 200 秒内创建 Job。 ### 并发性规则 `.spec.concurrencyPolicy` 也是可选的。它声明了 CronJob 创建的任务执行时发生重叠如何处理。 spec 仅能声明下列规则中的一种: * `Allow` (默认):CronJob 允许并发任务执行。 * `Forbid`: CronJob 不允许并发任务执行;如果新任务的执行时间到了而老任务没有执行完,CronJob 会忽略新任务的执行。 * `Replace`:如果新任务的执行时间到了而老任务没有执行完,CronJob 会用新任务替换当前正在运行的任务。 请注意,并发性规则仅适用于相同 CronJob 创建的任务。如果有多个 CronJob,它们相应的任务总是允许并发执行的。 ### 挂起 `.spec.suspend`域也是可选的。如果设置为 `true` ,后续发生的执行都会挂起。 这个设置对已经开始的执行不起作用。默认是关闭的。 {{< caution >}} 在调度时间内挂起的执行都会被统计为错过的任务。当 `.spec.suspend` 从 `true` 改为 `false` 时, 且没有 [开始的最后期限](#starting-deadline),错过的任务会被立即调度。 {{< /caution >}} ### 任务历史限制 `.spec.successfulJobsHistoryLimit` 和 `.spec.failedJobsHistoryLimit`是可选的。 这两个字段指定应保留多少已完成和失败的任务。 默认设置为3和1。限制设置为0代表相应类型的任务完成后不会保留。