8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2025-12-24 03:42:07 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

修复类型转化失败问题

Browse Source
This commit is contained in:
zengqiao
2022-09-15 11:32:44 +08:00
parent 5d412890b4
commit 37c3f69a28
2 changed files with 38 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/CommonUtils.java
View File

@@ -241,4 +241,14 @@ public class CommonUtils {
}
return intList;
}
public static boolean isNumeric(String str){
for (int i = 0; i < str.length(); i++){
if (!Character.isDigit(str.charAt(i))){
return false;
}
}
return true;
}
}

36
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java
View File

@@ -9,6 +9,7 @@ import com.xiaojukeji.know.streaming.km.common.bean.entity.search.*;
import com.xiaojukeji.know.streaming.km.common.bean.po.BaseESPO;
import com.xiaojukeji.know.streaming.km.common.bean.po.metrice.BaseMetricESPO;
import com.xiaojukeji.know.streaming.km.common.bean.vo.metrics.point.MetricPointVO;
import com.xiaojukeji.know.streaming.km.common.utils.CommonUtils;
import com.xiaojukeji.know.streaming.km.common.utils.IndexNameUtils;
import com.xiaojukeji.know.streaming.km.persistence.es.BaseESDAO;
import com.xiaojukeji.know.streaming.km.persistence.es.dsls.DslsConstant;
@@ -34,6 +35,8 @@ public class BaseMetricESDAO extends BaseESDAO {
protected static final Long ONE_HOUR = 60 * ONE_MIN;
protected static final Long ONE_DAY = 24 * ONE_HOUR;
private static final int INDEX_DAYS = 7;
/**
* 不同维度 kafka 监控数据
*/
@@ -45,12 +48,18 @@ public class BaseMetricESDAO extends BaseESDAO {
*/
@Scheduled(cron = "0 3/5 * * * ?")
public void checkCurrentDayIndexExist(){
String realIndex = IndexNameUtils.genCurrentDailyIndexName(indexName);
try {
esOpClient.createIndexTemplateIfNotExist(indexName, indexTemplate);
if(esOpClient.indexExist(realIndex)){return;}
//检查最近7天索引存在不存
for(int i = 0; i < INDEX_DAYS; i++){
String realIndex = IndexNameUtils.genDailyIndexName(indexName, i);
if(esOpClient.indexExist(realIndex)){continue;}
if(esOpClient.createIndexTemplateIfNotExist(indexName, indexTemplate)){
esOpClient.createIndex(realIndex);
esOpClient.createIndex(realIndex);
}
}catch (Exception e){
LOGGER.error("method=checkCurrentDayIndexExist||errMsg=exception!", e);
}
}
@@ -336,10 +345,17 @@ public class BaseMetricESDAO extends BaseESDAO {
if(null == response || null == response.getHits()
|| null ==response.getHits().getUnusedMap()){return -1;}
// "total" : {"value": 123 , "relation": "XX "}
JSONObject jsonObjectTotal = (JSONObject) response.getHits().getUnusedMap().getOrDefault(TOTAL, 0);
return Integer.valueOf(jsonObjectTotal.get(VALUE).toString());
try {
String total = response.getHits().getUnusedMap().get(TOTAL).toString();
if(CommonUtils.isNumeric(total)){
return Integer.valueOf(total);
}else {
return JSON.parseObject(total).getIntValue(VALUE);
}
}catch (Exception e){
LOGGER.error("method=handleESQueryResponseCount||errMsg=exception!", e);
}
return 0;
}
protected <T extends BaseMetricESPO> T filterMetrics(T t, List<String> metricNames){
@@ -389,6 +405,10 @@ public class BaseMetricESDAO extends BaseESDAO {
* 对 metricPointVOS 进行缺点优化
*/
protected List<MetricPointVO> optimizeMetricPoints(List<MetricPointVO> metricPointVOS){
// // 内部测试环境，不进行优化，直接返回
// return metricPointVOS;
// 开源环境，进行指标点优化
if(CollectionUtils.isEmpty(metricPointVOS)){return metricPointVOS;}
int size = metricPointVOS.size();