Jenkins Pipeline中如何检查并行分支的返回状态

43次阅读

问题描述

在Jenkins Pipeline中运行一个作业，该作业在多个节点上运行。以下是代码结构：

def branches = [:]
def allNodes = Jenkins.getInstance().getNodes()
for (int i =0; i < allNodes.size(); i++) {
    branches[allNodes[i].name.toString()] = {
        node(allNodes[i].name.toString()) {
            // 执行一些操作
        }
    }
}
parallel branches

现在，用户想要获取在节点上运行的作业部分的状态，以便在某个节点上的某个作业部分失败时，将该节点标记为离线。是否有办法实现这个需求？

解决方案

请注意以下操作注意版本差异及修改前做好备份。

方案1

你可以尝试使用Jenkins Join插件。该插件的一些详细信息如下（来自链接页面）：

该插件允许在所有直接下游作业完成后运行一个作业。通过这种方式，执行可以分支并并行执行多个步骤，然后在所有并行工作完成后运行最终的聚合步骤。
该插件对于创建“钻石”形状的项目依赖关系非常有用。这意味着有一个启动多个下游作业的单个父作业。一旦这些作业完成，就会运行一个单独的聚合作业。
有关更多详细信息，请参考我自己回答的关于“为什么远程触发（使用Jenkins）然后忘记它？”的问题。
以下是使用Join插件的步骤：
1. 在Jenkins中安装Join插件。
2. 在Jenkins Pipeline中使用Join插件的join步骤来等待并行分支的完成。
下面是一个示例：

def branches = [:]
def allNodes = Jenkins.getInstance().getNodes()
for (int i =0; i < allNodes.size(); i++) {
    branches[allNodes[i].name.toString()] = {
        node(allNodes[i].name.toString()) {
            // 执行一些操作
        }
    }
}
parallel branches

// 等待并行分支的完成
join()

使用Join插件的join步骤可以等待所有并行分支的完成。这样，你就可以在并行分支完成后继续执行其他操作。

方案2

使用文件来存储并传递作业部分的状态可能会增加复杂性，并且需要手动处理文件的创建、传递和删除。
另一种方法是使用文件来存储并传递作业部分的状态。你可以在节点上创建一个文件，将作业部分的状态写入文件，然后将文件传递回主节点进行处理。以下是一个示例：

def branches = [:]
def allNodes = Jenkins.getInstance().getNodes()
for (int i =0; i < allNodes.size(); i++) {
    String nodeName = allNodes[i].name.toString()
    branches[nodeName] = {
        node(nodeName) {
            // 执行一些操作
            String outputFile = nodeName + "-output"
            writeFile file: outputFile, text: result.toString()
            stash includes: "*output", name: outputFile
        }
    }
}
parallel branches

// 从主节点上获取文件并处理作业部分的状态
for (int i = 0; i < allNodes.size(); i++) {
    String filename = allNodes[i].name.toString() + "-output"
    unstash filename
    def value = readFile filename
    // 根据变量值标记节点离线
}

在上面的示例中，我们首先在每个节点上创建一个文件，并将作业部分的状态写入文件。然后，我们使用stash步骤将文件存储在节点上。最后，我们在主节点上使用unstash步骤获取文件，并根据文件中的变量值标记节点离线。
请注意，使用文件来存储作业部分的状态可能会增加复杂性，并且需要手动处理文件的创建、传递和删除。因此，这种方法可能不是最理想的解决方案，但可以作为一种临时的解决方案。