in ozhera-monitor/ozhera-monitor-service/src/main/java/org/apache/ozhera/monitor/service/impl/HeraDashboardServiceImpl.java [303:378]
public void createDefaultScrapeJob() {
//Get jobJson from a file
Map<String, Object> jaegerQueryMap = new HashMap<>();
jaegerQueryMap.put("token", jaegerQueryToken);
try {
//create jaeger_query monitor
Result jaegerResult = jobService.searchJobByName(null, "hera",
DashboardConstant.DEFAULT_JAEGER_QUERY_JOB_NAME);
log.info("jaegerResult:{}", jaegerResult);
if (jaegerResult.getData().equals("null")) {
log.info("jaeger_query job begin create");
String jaegerQueryJobJson = FreeMarkerUtil.getContent(HERA_SCRAPE_JOB_TEMPLATE,
"jaegerQueryScrapeJob.ftl", jaegerQueryMap);
Result jaegerQueryJobRes = jobService.createJob(null, "Hera", jaegerQueryJobJson, "初始化创建业务监控");
log.info("HeraDashboardService.createDefaultScrapeJob jaeger_query res: {}",
jaegerQueryJobRes.getData());
}
//create jvm monitor
Result jvmResult = jobService.searchJobByName(null, "hera", DashboardConstant.DEFAULT_JVM_JOB_NAME);
if (jvmResult.getData().equals("null")) {
log.info("jvm job begin create");
String jvmJobJson = FreeMarkerUtil.getContent(HERA_SCRAPE_JOB_TEMPLATE, "jvmScrapeJob.ftl",
new HashMap<>());
Result jvmJobJsonRes = jobService.createJob(null, "Hera", jvmJobJson, "初始化创建jvm监控");
log.info("HeraDashboardService.createDefaultScrapeJob jvm res: {}", jvmJobJsonRes.getData());
}
//create docker monitor
Result dockerResult = jobService.searchJobByName(null, "hera", DashboardConstant.DEFAULT_DOCKER_JOB_NAME);
if (dockerResult.getData().equals("null")) {
log.info("docker job begin create");
String dockerJobJson = FreeMarkerUtil.getContent(HERA_SCRAPE_JOB_TEMPLATE, "dockerScrapeJob.ftl",
new HashMap<>());
Result dockerJobJsonRes = jobService.createJob(null, "Hera", dockerJobJson, "初始化创建容器监控");
log.info("HeraDashboardService.createDefaultScrapeJob docker res: {}", dockerJobJsonRes.getData());
}
//create node monitor
Result nodeResult = jobService.searchJobByName(null, "hera", DashboardConstant.DEFAULT_NODE_JOB_NAME);
if (nodeResult.getData().equals("null")) {
log.info("node job begin create");
String nodeJobJson = FreeMarkerUtil.getContent(HERA_SCRAPE_JOB_TEMPLATE, "nodeScrapeJob.ftl",
new HashMap<>());
Result nodeJobJsonRes = jobService.createJob(null, "Hera", nodeJobJson, "初始化创建物理机监控");
log.info("HeraDashboardService.createDefaultScrapeJob node res: {}", nodeJobJsonRes.getData());
}
//create custom monitor
Result customizeResult = jobService.searchJobByName(null, "hera",
DashboardConstant.DEFAULT_CUSTOMIZE_JOB_NAME);
if (customizeResult.getData().equals("null")) {
log.info("customize job begin create");
String customizeJobJson = FreeMarkerUtil.getContent(HERA_SCRAPE_JOB_TEMPLATE, "customizeScrapeJob.ftl",
new HashMap<>());
Result customizeJobJsonRes = jobService.createJob(null, "Hera", customizeJobJson,
"初始化创建自定义监控");
log.info("HeraDashboardService.createDefaultScrapeJob customize res: {}",
customizeJobJsonRes.getData());
}
//create golang runtime monitor
Result golangRuntimeResult = jobService.searchJobByName(null, "hera",
DashboardConstant.DEFAULT_GOLANG_RUNTIME_JOB_NAME);
if (golangRuntimeResult.getData().equals("null")) {
log.info("golangRuntimeResult job begin create");
String golangRuntimeJobJson = FreeMarkerUtil.getContent(HERA_SCRAPE_JOB_TEMPLATE,
"golangRuntimeScrapeJob.ftl", new HashMap<>());
Result golangRuntimeJobJsonRes = jobService.createJob(null, "Hera", golangRuntimeJobJson,
"初始化创建golang Runtime监控");
log.info("HeraDashboardService.createDefaultScrapeJob golang runtime res: {}",
golangRuntimeJobJsonRes.getData());
}
} catch (Exception e) {
log.error("HeraDashboardService.createDefaultScrapeJob error :{}", e.getMessage());
}
}