feat. auto update tbb meta

Author: yjeong-hz

.env

@@ -34,5 +34,6 @@ COST_PROCESS_ABNORMAL_CRON_SCHEDULE=0 0 1,7 * * ?
 COST_SELECTOR_URL=http://costselector:8083
 ALARM_URL=http://alarmservice:9000
 # AssetCollector
+COST_BE_URL=http://be:9090
 ASSET_MONITORING_SERVER=http://asset.mornitor.server:8080
 ASSET_COLLECT_BATCH_CRON_SCHEDULE=0 0 0 * * ?

assetCollector/src/main/java/com/mcmp/assetcollector/batch/AssetCollect.java

@@ -52,6 +52,9 @@ public class AssetCollect {
     @Autowired
     private AssetCollectService assetCollectService;
 
+    @Autowired
+    private UpdateMetaBeforeAssetJob updateMetaBeforeAssetJob;
+
     @Bean
     public SkipLogListener skipLogListener(){
         return new SkipLogListener();
@@ -61,6 +64,7 @@ public SkipLogListener skipLogListener(){
     public Job assetCollectJob(JobRepository jobRepository, Step assetCollectStep) {
         return new JobBuilder("assetCollectJob", jobRepository)
                 .start(assetCollectStep)
+                .listener(updateMetaBeforeAssetJob)
                 .build();
     }
 
@@ -127,6 +131,10 @@ public ItemProcessor<RunningInstanceModel, List<RSRCAssetComputeMetricModel>> pr
                                 OffsetDateTime offsetDateTime = OffsetDateTime.parse(timestampString, DateTimeFormatter.ISO_DATE_TIME);
                                 Timestamp timestamp = Timestamp.valueOf(offsetDateTime.atZoneSameInstant(ZoneOffset.UTC).toLocalDateTime());
 
+                                if(value.get(valueIndex) == null){
+                                    log.warn("item : {}'s value is null when {}", item, timestamp);
+                                    continue;
+                                }
                                 Double asset_idle_Value = (Double) value.get(valueIndex);
                                 Double roundedValue = Math.round(asset_idle_Value * 100.0) / 100.0;
                                 Double usageValue = 100 - roundedValue;

assetCollector/src/main/java/com/mcmp/assetcollector/batch/UpdateMetaBeforeAssetJob.java

@@ -0,0 +1,29 @@
+package com.mcmp.assetcollector.batch;
+
+import com.mcmp.assetcollector.service.MetaService;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.catalina.core.ApplicationContext;
+import org.springframework.batch.core.JobExecution;
+import org.springframework.batch.core.JobExecutionListener;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.AnnotationConfigApplicationContext;
+import org.springframework.stereotype.Component;
+
+@Component
+@Slf4j
+public class UpdateMetaBeforeAssetJob implements JobExecutionListener {
+
+    @Autowired
+    private MetaService metaService;
+
+    @Override
+    public void beforeJob(JobExecution jobExecution){
+        try{
+            metaService.updateSvcGrpMeta();
+        } catch (Exception e){
+            log.error("[AssetCollect] Update ServiceGroup Meta Error : {}", e.getMessage());
+            e.printStackTrace();
+        }
+
+    }
+}

assetCollector/src/main/java/com/mcmp/assetcollector/service/MetaService.java

@@ -0,0 +1,26 @@
+package com.mcmp.assetcollector.service;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+@Service
+@Slf4j
+public class MetaService {
+    @Value("${costopti.be.url}")
+    private String costoptiBEUrl;
+
+    public void updateSvcGrpMeta() {
+        RestTemplate restTemplate = new RestTemplate();
+        String apiUrl = String.format("%s/api/costopti/be/updateRscMeta", costoptiBEUrl);
+
+        HttpHeaders httpHeaders = new HttpHeaders();
+        HttpEntity<?> httpEntity = new HttpEntity<>(httpHeaders);
+
+        restTemplate.exchange(apiUrl, HttpMethod.GET, httpEntity, Void.class);
+    }
+}

assetCollector/src/main/resources/application.properties

@@ -17,6 +17,7 @@ spring.datasource.hikari.batch.remove-abandoned-timeout=30
 logging.level.org.springframework.batch=DEBUG
 logging.level.org.mybatis=DEBUG
 
-asset.collect.url=http://monitoring.server:8080
+costopti.be.url=http://localhost:9090
+asset.collect.url=http://observability.server:8080
 
-assetCollectBatchCronSchedule=0 0 0 * * ?
+assetCollectBatchCronSchedule=0 10 * * * ?

docker-compose.yml

@@ -105,6 +105,7 @@ services:
       spring.datasource.hikari.batch.jdbc-url: ${COST_DB_URL}
       spring.datasource.hikari.batch.username: ${COST_DB_USERNM}
       spring.datasource.hikari.batch.password: ${COST_DB_PW}
+      costopti.be.url: ${COST_BE_URL}
       asset.collect.url: ${ASSET_MONITORING_SERVER}
       assetCollectBatchCronSchedule: ${ASSET_COLLECT_BATCH_CRON_SCHEDULE}
 networks: