public void createDefaultScrapeJob()

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());
        }
        
    }