一站式织梦网站模板国际重大新闻事件2023

背景

搭建效能看板，需要获取jenkins中一些job的数据作为数据源输入。
使用node配合jenkins库进行数据获取，jenkins库为：https://www.npmjs.com/package/jenkins
安装：npm i jenkins

准备工作

使用Jenkins获取数据需要知道Jenkins的URL，以及用户名和apiToken。
Jenkins中每个用于构建和测试代码的项目被称为Job，它是 Jenkins 的基本执行单元。
想要同时获取多个job中的数据，可以通过View将Job分类。Jenkins View 是一个逻辑分组工具，用于对 Job 进行分类和管理。随着 Jenkins 中 Job 数量的增加，View 可以帮助用户更清晰地组织和查找任务。
这里我们将需要统计的Job都放到View1中。

代码

const jenkinsApi = require('jenkins');
const moment = require('moment');async function getJobBuildHistory({jenkinsUrl,viewName,username,apiToken,startTime,endTime
}) {const jenkins = new jenkinsApi({ baseUrl: `http://${username}:${apiToken}@${jenkinsUrl}`, crumbIssuer: true });const end = endTime ? moment(endTime) : moment();const start = startTime ? moment(startTime) : end.clone().subtract(1, 'days');const startTs = start.valueOf();const endTs = end.valueOf();try {const view = await jenkins.view.get(viewName);const jobs = view.jobs.map(job => job.name);const buildHistory = [];for (const jobName of jobs) {try {const builds = await jenkins.job.get(jobName, { depth: 1 });for (const build of builds.builds) {const buildInfo = await jenkins.build.get(jobName, build.number);const buildTs = moment(buildInfo.timestamp).valueOf();if (buildTs < startTs) {break;}if (buildTs > endTs) continue;buildHistory.push({jobName,buildNumber: build.number,startTime: moment(buildInfo.timestamp).format('YYYY/MM/DD-HH:mm:ss'),duration: Math.round(buildInfo.duration / 1000),status: buildInfo.result || 'RUNNING',triggeredBy: buildInfo.actions.find(a => a?.causes)?.causes[0]?.shortDescription?.replace('Started by ', '') || 'UNKNOWN'});}} catch (e) {console.error(`  Job processing failed: ${e.message}`);}}return buildHistory;} catch (e) {throw new Error(`View error: ${e.message}`);}
}exports.getCiData = async (req, res) => {const { startTime, endTime } = req.body;try {const history = await getJobBuildHistory({jenkinsUrl: 'your jenkins url,viewName: 'View1',username: 'your username',apiToken: 'your token',startTime,endTime});return res.success(history, 200, '查询成功');} catch (error) {return res.server_error(error);}
};