k8s_用CronJob控制器实现定期任务举例

2024-06-14 17:04

本文主要是介绍k8s_用CronJob控制器实现定期任务举例,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在Kubernetes中,Job是用于一次性任务的控制器,而CronJob是用于定期执行任务的控制器。要定期运行多个Pod任务并设置任务完成时间,我们可以使用CronJob。以下是一个示例,展示如何配置一个定期运行的CronJob,该CronJob会运行多个Pod任务,并设置任务的完成时间限制。

CronJob 示例

以下示例展示了一个CronJob,它每小时运行一次任务,任务运行的Pod最多可以执行5分钟(300秒),之后会被终止。

CronJob YAML 文件
apiVersion: batch/v1
kind: CronJob
metadata:name: my-cronjob
spec:schedule: "0 * * * *"  # 每小时运行一次jobTemplate:spec:completions: 3  # 任务完成所需的Pod数parallelism: 3  # 并行运行的Pod数activeDeadlineSeconds: 300  # 每个任务最多执行300秒(5分钟)template:metadata:labels:app: my-cronjobspec:containers:- name: my-taskimage: busyboxargs:- /bin/sh- -c- "echo Hello, Kubernetes! && sleep 120"  # 模拟任务运行时间restartPolicy: OnFailure  # Pod失败时重启策略

解释

  1. apiVersion 和 kind

    • apiVersion: batch/v1:指定使用的Kubernetes API版本。
    • kind: CronJob:声明资源类型为CronJob
  2. metadata

    • name: my-cronjobCronJob的名称。
  3. spec

    • schedule: "0 * * * *":任务调度的时间表达式,表示每小时的第0分钟运行一次任务。
    • jobTemplate:定义任务的模板。
      • completions: 3:指定任务需要成功完成3次。
      • parallelism: 3:指定任务可以并行运行的Pod数量。
      • activeDeadlineSeconds: 300:每个任务最多执行300秒(5分钟),超过时间将被终止。
      • template:定义Pod模板。
        • metadata
          • labels:Pod的标签。
        • spec
          • containers:定义容器列表。
            • name: my-task:容器名称。
            • image: busybox:使用busybox镜像。
            • args:指定容器的运行命令。
              • echo Hello, Kubernetes! && sleep 120:打印信息并模拟任务运行120秒。
          • restartPolicy: OnFailure:指定Pod失败时的重启策略,设置为OnFailure表示任务失败时会重启Pod。

部署和验证

  1. 部署CronJob
    将上述YAML文件保存为my-cronjob.yaml,然后使用以下命令创建CronJob

    kubectl apply -f my-cronjob.yaml
    
  2. 查看CronJob状态
    运行以下命令查看CronJob的状态和运行的Job:

    kubectl get cronjob my-cronjob
    kubectl get jobs
    
  3. 查看Pod日志
    找到由Job创建的Pod,查看其日志:

    kubectl get pods
    kubectl logs <pod-name>
    

这个示例展示了如何使用CronJob定期运行多个Pod任务,并设置任务完成时间。根据需要,您可以调整调度时间、并行运行的Pod数、任务完成所需的Pod数和最大执行时间。

这篇关于k8s_用CronJob控制器实现定期任务举例的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1060994

相关文章

C++对象布局及多态实现探索之内存布局(整理的很多链接)

本文通过观察对象的内存布局,跟踪函数调用的汇编代码。分析了C++对象内存的布局情况,虚函数的执行方式,以及虚继承,等等 文章链接:http://dev.yesky.com/254/2191254.shtml      论C/C++函数间动态内存的传递 (2005-07-30)   当你涉及到C/C++的核心编程的时候,你会无止境地与内存管理打交道。 文章链接:http://dev.yesky

通过SSH隧道实现通过远程服务器上外网

搭建隧道 autossh -M 0 -f -D 1080 -C -N user1@remotehost##验证隧道是否生效,查看1080端口是否启动netstat -tuln | grep 1080## 测试ssh 隧道是否生效curl -x socks5h://127.0.0.1:1080 -I http://www.github.com 将autossh 设置为服务,隧道开机启动

时序预测 | MATLAB实现LSTM时间序列未来多步预测-递归预测

时序预测 | MATLAB实现LSTM时间序列未来多步预测-递归预测 目录 时序预测 | MATLAB实现LSTM时间序列未来多步预测-递归预测基本介绍程序设计参考资料 基本介绍 MATLAB实现LSTM时间序列未来多步预测-递归预测。LSTM是一种含有LSTM区块(blocks)或其他的一种类神经网络,文献或其他资料中LSTM区块可能被描述成智能网络单元,因为

vue项目集成CanvasEditor实现Word在线编辑器

CanvasEditor实现Word在线编辑器 官网文档:https://hufe.club/canvas-editor-docs/guide/schema.html 源码地址:https://github.com/Hufe921/canvas-editor 前提声明: 由于CanvasEditor目前不支持vue、react 等框架开箱即用版,所以需要我们去Git下载源码,拿到其中两个主

android一键分享功能部分实现

为什么叫做部分实现呢,其实是我只实现一部分的分享。如新浪微博,那还有没去实现的是微信分享。还有一部分奇怪的问题:我QQ分享跟QQ空间的分享功能,我都没配置key那些都是原本集成就有的key也可以实现分享,谁清楚的麻烦详解下。 实现分享功能我们可以去www.mob.com这个网站集成。免费的,而且还有短信验证功能。等这分享研究完后就研究下短信验证功能。 开始实现步骤(新浪分享,以下是本人自己实现

基于Springboot + vue 的抗疫物质管理系统的设计与实现

目录 📚 前言 📑摘要 📑系统流程 📚 系统架构设计 📚 数据库设计 📚 系统功能的具体实现    💬 系统登录注册 系统登录 登录界面   用户添加  💬 抗疫列表展示模块     区域信息管理 添加物资详情 抗疫物资列表展示 抗疫物资申请 抗疫物资审核 ✒️ 源码实现 💖 源码获取 😁 联系方式 📚 前言 📑博客主页:

探索蓝牙协议的奥秘:用ESP32实现高质量蓝牙音频传输

蓝牙(Bluetooth)是一种短距离无线通信技术,广泛应用于各种电子设备之间的数据传输。自1994年由爱立信公司首次提出以来,蓝牙技术已经经历了多个版本的更新和改进。本文将详细介绍蓝牙协议,并通过一个具体的项目——使用ESP32实现蓝牙音频传输,来展示蓝牙协议的实际应用及其优点。 蓝牙协议概述 蓝牙协议栈 蓝牙协议栈是蓝牙技术的核心,定义了蓝牙设备之间如何进行通信。蓝牙协议

python实现最简单循环神经网络(RNNs)

Recurrent Neural Networks(RNNs) 的模型: 上图中红色部分是输入向量。文本、单词、数据都是输入,在网络里都以向量的形式进行表示。 绿色部分是隐藏向量。是加工处理过程。 蓝色部分是输出向量。 python代码表示如下: rnn = RNN()y = rnn.step(x) # x为输入向量,y为输出向量 RNNs神经网络由神经元组成, python

利用Frp实现内网穿透(docker实现)

文章目录 1、WSL子系统配置2、腾讯云服务器安装frps2.1、创建配置文件2.2 、创建frps容器 3、WSL2子系统Centos服务器安装frpc服务3.1、安装docker3.2、创建配置文件3.3 、创建frpc容器 4、WSL2子系统Centos服务器安装nginx服务 环境配置:一台公网服务器(腾讯云)、一台笔记本电脑、WSL子系统涉及知识:docker、Frp

基于 Java 实现的智能客服聊天工具模拟场景

服务端代码 import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.PrintWriter;import java.net.ServerSocket;import java.net.Socket;public class Serv