Jenkins特意为了更好使用pipeline，开发了一些工具类，方便我们更好地在step中处理各种需求。
Pipeline Utility Steps
这是个插件，需要在jenkins插件管理安装。参考来源：Jenkins高级篇之Pipeline方法篇-Pipeline Utility Steps-2-方法readJSON和writeJSON_pipeline readjson-CSDN博客
1、findFiles （需要在项目下要有log文件）
2、readJSON （方法有两种参数，分别是文件路径和字符串；示例是文件路径；datas = readJSON text : json_string）
3、writeJSON （file入参是文件路径，json可以是readJSON的结果，也可以是转换为json的字符串；示例是writeJSON的方式）
4、readProperties （读取properties文件，得到是一个map对象）
5、readYaml （读取yaml文件，得到是一个map对象；有2种参数，同上面的readJson； datas = readYaml text : yaml_string）
6、writeYaml （入参是readYaml的结果，也可以是一个map）
pipeline {
agent any
stages {
stage('env') {
steps {
script {
println env.JOB_NAME
println env.BUILD_NUMBER
println env.WORKSPACE
}
}
}
stage('Utility Steps method---findFiles') {
steps {
script {
files = findFiles(glob: '**/*.log')
println files[0].name
}
}
}
stage('Utility Steps method---readJSON') {
steps {
script {
file_path_read = env.WORKSPACE + "/package.json"
rd_json = readJSON file : file_path_read
println rd_json
println rd_json.name
}
}
}
stage('Utility Steps method---writeJSON') {
steps {
script {
file_path_write = env.WORKSPACE + "/test_jenkins.json"
input_json = env.WORKSPACE + "/package.json"
input = readJSON file : input_json
writeJSON file: file_path_write, json: input
}
}
}
stage('Utility Steps method---readProperties') {
steps {
script {
properties_file = env.WORKSPACE + "/test_jenkins.properties"
props = readProperties interpolate: true, file: properties_file
println props
}
}
}
stage('Utility Steps method---readYaml') {
steps {
script {
yaml_file = env.WORKSPACE + "/test_jenkins.yaml"
y = readYaml file : yaml_file
println y
}
}
}
stage('Utility Steps method---writeYaml') {
steps {
script {
yaml_path = env.WORKSPACE + "/test_jenkins_write.yaml"
input_path = env.WORKSPACE + "/test_jenkins.yaml"
input_map = readYaml file : input_path
writeYaml file: yaml_path , data: input_map
}
}
}
}
}
这是一个最基础的pipeline组件，这个也是一个独立的插件，在安装pipeline的时候默认会自动安装
官网：Pipeline: Basic Steps
1、deleteDir()
这个是默认递归删除WORKSPACE下的文件和文件夹
使用场景：做完了每一个stage里面的事情，我们需要在post{...}里面写一些clean up操作
2、dir()
这个方法是改变当前的工作目录
3、error()
遇到这个方法，该stage和后面的stage都会显示失败
4、fileExists
判断一个文件是否存在，返回值是布尔类型
5、isUnix()
判断当前运行的Jenkins node环境是不是linux环境
6、pwd()
linux是pwd，windows上是dir。所以这个插件就干脆支持一个方法，统称为pwd()
pipeline{
agent any
stages{
stage("dir") {
steps{
// 如果没有这个目录，会自动创建这个目录
dir("${env.WORKSPACE}/testdata"){
sh "pwd"
}
}
}
stage("fileExists") {
steps{
script {
json_file = "${env.WORKSPACE}/test_jenkins.log"
if(fileExists(json_file) == true) {
echo("log file is exists")
}else {
error("here haven't find log file")
}
}
}
}
stage("isUnix") {
steps{
script {
if(isUnix() == true) {
echo("this jenkins job running on a linux-like system")
}else {
error("the jenkins job running on a windows system")
}
}
}
}
stage("pwd()") {
steps{
script {
sh("pwd")
println "==========="
println pwd()
}
}
}
}
post {
always {
script {
//写相关清除/恢复环境等操作代码
//deleteDir()
println "结束"
}
}
}
}
pipeline{
agent any
environment {
to_email = "yin921125@qq.com"
to_email_address_list = "yin921125@qq.com,yin921125@163.com"
}
stages{
stage("发邮件demo 1") {
steps{
script {
mail to: to_email,
subject: "Running Pipeline: ${currentBuild.fullDisplayName}",
body: "Something is wrong with ${env.BUILD_URL}"
}
}
}
stage("发邮件demo 2") {
steps{
script {
mail to: to_email,
cc: 'xxxxx@qq.com', // 抄送
charset:'UTF-8', // or GBK/GB18030
mimeType:'text/plain', // or text/html
subject: "Running Pipeline: ${currentBuild.fullDisplayName}",
body: "Something is wrong with ${env.BUILD_URL}, just for test send mail via pipeline code"
}
}
}
stage("发邮件demo 3") {
steps{
script {
subject = "Jenkins Job : " + env.JOB_NAME + "/" + env.BUILD_ID
result_url = env.BUILD_URL + "console"
text = """
Summary
Jenkins Build
- Job URL : ${env.BUILD_URL}
- Build Result URL : ${result_url}
GIT Branch
- 这是一个测试分支
"""
mail body: text, subject: subject, mimeType: 'text/html', to: to_email_address_list
}
}
}
}
post{
always{
script {
module_test = load env.WORKSPACE + "/test_groovy.groovy"
}
}
failure {
script {
module_test.send_email_results("Failed","Master",to_email_address_list)
}
}
success {
script {
module_test.send_email_results("Success","Master",to_email_address_list)
}
}
}
}
上面引用的test_groovy.groovy如下
def send_email_results(status,GITBranch,to_email_address_list) {
subject = "Jenkins Job : " + env.JOB_NAME + "/" + env.BUILD_ID + " has " + status
result_url = env.BUILD_URL + "console"
text = """
Summary
Jenkins Build
- Job URL : ${env.BUILD_URL}
- Build Result URL : ${result_url}
GIT Branch
- 这是测试引用其他groovy文件的邮件${GITBranch}
"""
mail body: text, subject: subject, mimeType: 'text/html', to: to_email_address_list
}
return this
1、readFile，读取文件内容（两个参数，第一个是file的path，第二个是encoding，默认是根据你当前平台的编码）
如果不知道文件是什么格式（格式例如txt,log,json,properties,config,yaml），则推荐用readFile
如果拿来读一个图片或者音频视频文件，读取二进制文件会采用Base64转码的字符串输出。
2、retry和sleep
retry只能在出现异常的地方才能使用，否则只跑一遍就结束
retry(3)这个3是一个整数，表示尝试的次数，sleep中的2表示2秒，注意这单位是秒
pipeline{
agent any
stages{
stage("init") {
steps{
script {
json_file = "${env.WORKSPACE}/package.json"
file_contents = readFile json_file
println file_contents
}
}
}
stage("retry and sleep") {
steps{
script{
try {
retry(3) {
println "here we are test retry fuction"
sleep 5
println 10/0
}
}catch (Exception e) {
println e
}
}
}
}
}
}
1、timeout （超时则aborted）
2、waitUntil （直到返回true才跳出，否则一直重试）
3、withEnv （添加环境变量）
pipeline{
agent any
stages{
stage("init") {
steps{
script {
// 设置超时5s，默认单位是分钟
timeout(time: 50, unit: 'SECONDS') {
//initialRecurrencePeriod ：设置重试之间的初始等待时间（以毫秒为单位）。
// 默认为 250 毫秒。每次失败都会将尝试之间的延迟减慢至最多 15 秒
//quiet ：如果为真，则每次检查条件时该步骤都不会记录消息。默认为假。类型： boolean
println "是unix系统吗" + isUnix()
waitUntil(initialRecurrencePeriod: 1000,quiet: true){
script {
isUnix()
}
}
}
}
}
}
stage("env") {
steps{
script {
withEnv(['java_home=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.181-3.b13.el6_10.i386/jre']) {
sh("$java_home/bin/java -version")
println "test with withEnv feature"
}
}
}
}
}
}
println env.JOB_NAME
println env.BUILD_NUMBER
pipeline{
agent any
stages{
stage("writeFile demo") {
steps{
script {
write_file_path = "${env.WORKSPACE}/test_jenkins.txt"
file_contents = "Hello Anthony!! 这是一个测试例子"
// 写文件
writeFile file: write_file_path, text: file_contents, encoding: "UTF-8"
// 读文件
fileContents = readFile file: write_file_path, encoding: "UTF-8"
println fileContents
}
}
}
}
}