gfwleak/nezha-nz-transfer
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 处理原来nezha自监控提供指标变更图表无法展示问题

Browse Source
This commit is contained in:
tanghao
2021-06-10 17:13:50 +08:00
parent 4deff29620
commit 8817ee5533
1 changed files with 21 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/main/java/com/nis/service/impl/ChartServiceImpl.java
View File

@@ -38,6 +38,8 @@ import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Set; import java.util.Set;
import java.util.function.Function; import java.util.function.Function;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@@ -129,10 +131,29 @@ public class ChartServiceImpl extends ServiceImpl<ChartDao, Chart> implements Ch
// 同步chartElement // 同步chartElement
List<VisualChartElement> visualChartElements = new ArrayList<VisualChartElement>(); List<VisualChartElement> visualChartElements = new ArrayList<VisualChartElement>();
List<ChartElement> chartElements = chartElementService.list(); List<ChartElement> chartElements = chartElementService.list();
Pattern pattern = Pattern.compile("\"(.*?)\"");
for(ChartElement chartElement:chartElements) { for(ChartElement chartElement:chartElements) {
VisualChartElement visualChartElement = new VisualChartElement(); VisualChartElement visualChartElement = new VisualChartElement();
String expression = chartElement.getExpression(); String expression = chartElement.getExpression();
expression = expression.replaceAll("endpoint=", "endpoint_id="); expression = expression.replaceAll("endpoint=", "endpoint_id=");
if(expression.startsWith("sum(nz_asset_nums)")&&expression.endsWith("sum(nz_asset_online_nums)")) {
expression = "sum(nz_asset_nums{state='Not in storage'})";
}
if(expression.startsWith("sum(nz_asset_nums)-count(nz_asset_ping)")) {
expression = "count(probe_success==0)";
}
if(expression.startsWith("nz_asset_ping{host=")) {
Matcher matcher = pattern.matcher(expression);
String host="";
if(matcher.find()) {
host = matcher.group();
}
if(StrUtil.isNotBlank(host)) {
expression="probe_icmp_duration_seconds{phase='rtt',host="+host+"} * 1000";
}
}
chartElement.setExpression(expression); chartElement.setExpression(expression);
BeanUtil.copyProperties(chartElement, visualChartElement); BeanUtil.copyProperties(chartElement, visualChartElement);
visualChartElements.add(visualChartElement); visualChartElements.add(visualChartElement);