直接调用 clientset.batchv1().cronjobs(ns).create() 创建 cronjob，需显式指定 namespace、合法 cron 表达式、onfailure/ never 重启策略及非空容器；更新 schedule 推荐删重建；查失败日志需沿 cronjob→job→pod 链路获取；未触发常因 controller 异常、utc 时区误解或 startingdeadlineseconds 过小。
如何用 client-go 创建 CronJob 对象
直接调用 clientset.BatchV1().CronJobs() 的 Create() 方法即可，但必须确保命名空间、RBAC 权限和字段合法性。Kubernetes 不接受空 spec.schedule 或缺失 spec.jobTemplate.spec.template.spec.containers 的对象。
-
metadata.namespace必须显式指定，不能留空（默认 namespace 不生效） -
spec.schedule必须是合法 cron 表达式，如"0 * * * *"；"@hourly"等别名不被 client-go 或 API Server 接受 -
spec.jobTemplate.spec.template.spec.restartPolicy只能是"OnFailure"或"Never"；设为"Always"会返回 422 错误 - 容器镜像需可拉取，若使用私有 registry，必须提前配置
imagePullSecrets
job := &batchv1.CronJob{
ObjectMeta: metav1.ObjectMeta{
Name: "hello-cron",
Namespace: "default",
},
Spec: batchv1.CronJobSpec{
Schedule: "*/5 * * * *",
JobTemplate: batchv1.JobTemplateSpec{
Spec: batchv1.JobSpec{
Template: corev1.PodTemplateSpec{
Spec: corev1.PodSpec{
RestartPolicy: "OnFailure",
Containers: []corev1.Container{{
Name: "hello",
Image: "busybox:1.35",
Command: []string{"/bin/sh", "-c"},
Args: []string{"echo 'Hello from CronJob' && date"},
}},
},
},
},
},
},
}
_, err := clientset.BatchV1().CronJobs("default").Create(context.TODO(), job, metav1.CreateOptions{})如何更新 CronJob 的 schedule 字段
不能直接 PATCH spec.schedule —— Kubernetes 默认拒绝对已存在 CronJob 的 schedule 字段进行变更（除非启用 CronJobV2 特性门控且集群版本 ≥ v1.25）。实际中更稳妥的做法是删除后重建，或改用 Replace() 全量更新。
- v1.21–v1.24：直接 PATCH
spec.schedule会返回Forbidden: field is immutable - v1.25+ 且开启
CronJobV2：可用StrategicMergePatchType更新，但需确认 kube-apiserver 启动参数含--feature-gates=CronJobV2=true - 生产环境建议用
Delete()+Create()组合，避免状态残留
如何监听 CronJob 执行失败并获取最近一次 Job 日志
CronJob 本身不存日志，它只触发 Job；真正运行的是由 CronJob 创建的 Job 对象，而 Job 控制器再创建 Pod。所以要查失败原因，得顺着 CronJob → 最新 Job → 最新 Pod 的链路查。
请注意以下说明:1、本程序允许任何人免费使用。2、本程序采用PHP+MYSQL架构编写。并且经过ZEND加密，所以运行环境需要有ZEND引擎支持。3、需要售后服务的，请与本作者联系，联系方式见下方。4、本程序还可以与您的网站想整合，可以实现用户在线服务功能，可以让客户管理自己的信息，可以查询自己的订单状况。以及返点信息等相关客户利益的信息。这个功能可提高客户的向心度。安装方法：1、解压本系统，放在
- 先用
List()查ownerReferences匹配该 CronJob 的 Job 列表，按creationTimestamp降序取第一个 - 再查该 Job 下所有 Pod，同样按时间取最新一个
- 最后用
corev1.Pods(pod.Namespace).GetLogs(pod.Name, &corev1.PodLogOptions{})获取日志 - 注意：若 Pod 已终止且未配置
ttlSecondsAfterFinished，日志可能不可读
为什么 CronJob 创建后没触发任何 Job？常见卡点
不是代码写错，而是控制器层面被拦住。最常被忽略的三个点：
立即学习“go语言免费学习笔记（深入）”；
- Kubernetes 控制平面中
cronjob-controller组件是否正常运行？可通过kubectl get pods -n kube-system | grep cronjob确认 - 集群时区是否与 CronJob 中 schedule 表达式预期一致？API Server 使用 UTC，不是节点本地时区
- CronJob 对象的
spec.startingDeadlineSeconds是否过小？若上次调度错过（比如 controller 宕机），且该值设为 60，那么超过 1 分钟未执行就会跳过，不会补作业
调试时优先检查 kubectl describe cronjob <name></name> 输出中的 Events 和 Last Schedule 字段，比翻 Go 日志更快。
