CI/CD：基于K8s弹性资源池的配置【第二步】编写Pipeline脚本实现自动化

上一篇文章 CI/CD：基于K8s弹性资源池的配置【第一步】自动化创建Jenkins的Agent节点我们通过运行Jenkins Groovy脚本来增加了一个Jenkins Agent节点。那么现在思考一个问题，弹性构建的实现方式有多种，如果我们的实现方式是：

运行Pipeline作业时启动一个Jenkins Agent 节点，然后作业结束后回收此节点。

该如何实现？大概的步骤：

创建Jenkins Agent；
获取Jenkins Agent的参数；
渲染yaml模板；
调用K8s API在固定的NS中创建一个Pod；
调度Jenkins pipeline到agent；

这么多步骤实现起来还是有点复杂的，本文我们先实现第1和2步骤。（还记得上篇文章中提到的一个关于序列化的问题，这次我们通过ScriptConsole 来解决）

实现思路

也就是说我们将上篇文章写的groovy脚本，存储到SharedLibrary中，然后调用ScriptConsole来运行。

将脚本上传到resources/scripts 目录中，然后pipeline中导入共享库，并加载 libraryResource

代码语言：javascript复制

@Library("mylib@feature-k8s") _     //加载共享库
import org.devops.*      

env.namespace = "jenkins"
env.agentName = "jenkinsagent${UUID.randomUUID().toString()[0..7]}"

因为脚本是通过ScriptConsole运行，所以这里需要通过API来完成，于是有了下面的方法：

代码语言：javascript复制

// ScriptConsole运行脚本
def RunScriptConsole(scriptContent, crumb){
    response = sh returnStdout: true, 
                  script: """
                    curl -s -d "script=$(cat ${scriptContent})" 
                    --header "Jenkins-Crumb:${crumb}" 
                    -X  POST http://admin:112374bd5c557010386b55bb85a777aded@192.168.1.200:8080/scriptText
                    """
    try {
        response = readJSON text: response - "Result: "
    } catch(e){
        println(e)
    }
    return response
}


// 获取Crumb值
def GetCrumb(){
    response = sh returnStdout: true, 
                  script: """ curl -s -u admin:admin 
                                   --location 
                                   --request GET 'http://192.168.1.200:8080/crumbIssuer/api/json' """
    response = readJSON text: response
    return  response.crumb
}

上面的代码没有做太多的优化，存在明文密码的问题，后面可以试着放到凭据中完善一下。这里注意：

需要通过Crumb API获取value，并添加到HTTP request中的header中。
使用Jenkis用户名和API token进行认证。

封装Pipeline

加载resource中的脚本，然后写到本地文件，然后通过API 在 ScriptConsole中运行。

代码语言：javascript复制

stage("CreateBuildENV"){
    steps{
        script{
            // Get agent create script
            scriptContent = libraryResource 'scripts/create_jenkins_agent.groovy'
            scriptContent = scriptContent.replaceAll("__AGENT_NAME__","${env.agentName}")
            writeFile file: 'create_jenkins_agent.groovy', text: scriptContent

            // Run agent create script
            jenkinsCrumb = GetCrumb()
            agentConfig = RunScriptConsole("create_jenkins_agent.groovy", jenkinsCrumb)
        }
    }
}

代码语言：javascript复制

 stage("DeleteBuildENV"){
      steps{
          script{
              //Delete kubernetes agent pod


              //Delete jenkins agent
              // Get agent delete script
              scriptContent = libraryResource 'scripts/delete_jenkins_agent.groovy'
              scriptContent = scriptContent.replaceAll("__AGENT_NAME__","${env.agentName}")
              writeFile file: 'delete_jenkins_agent.groovy', text: scriptContent

              // Run agent delete script
              jenkinsCrumb = GetCrumb()
              agentConfig = RunScriptConsole("delete_jenkins_agent.groovy", jenkinsCrumb)
          }
      }
  }

总结

通过上述的步骤，当你运行流水线的时候会自动创建一个Jenkins Agent（当然现在仅是创建Agent，但是Agent并没有连接到Master节点，所以无法运行Pipeline）能够看到效果是Agent的自动添加和销毁。

api kubernetes jenkins

0 人点赞