Authored by zhengyouwei

移除Aws库

... ... @@ -68,7 +68,7 @@ public class JavaApiStaticsMapper implements IJavaApiStaticsMapper {
Point point = pointBuilder.build();
batchPoints.point(point);
inluxDBSingle.getInfluxDBByName(InfluxDBContants.AWS).getInfluxDB()
inluxDBSingle.getInfluxDBByName(InfluxDBContants.ALARM).getInfluxDB()
.write(batchPoints);
... ... @@ -84,7 +84,7 @@ public class JavaApiStaticsMapper implements IJavaApiStaticsMapper {
sql += " order by time desc limit 1";
Query query = new Query(sql, InfluxDBContants.APP_ALARM);
QueryResult result = inluxDBSingle.getInfluxDBByName(InfluxDBContants.AWS).getInfluxDB().query(query);
QueryResult result = inluxDBSingle.getInfluxDBByName(InfluxDBContants.ALARM).getInfluxDB().query(query);
JavaApiStaticsModel javaApiStaticsModel = new JavaApiStaticsModel();
javaApiStaticsModel.setServiceId(api_id);
... ... @@ -170,7 +170,7 @@ public class JavaApiStaticsMapper implements IJavaApiStaticsMapper {
log.info("sql:{}", sql);
Query query = new Query(sql, InfluxDBContants.APP_ALARM);
QueryResult result = inluxDBSingle.getInfluxDBByName(InfluxDBContants.AWS).getInfluxDB().query(query);
QueryResult result = inluxDBSingle.getInfluxDBByName(InfluxDBContants.ALARM).getInfluxDB().query(query);
List<JavaApiStaticsModel> list = new ArrayList<JavaApiStaticsModel>();
... ... @@ -260,7 +260,7 @@ public class JavaApiStaticsMapper implements IJavaApiStaticsMapper {
Query query = new Query(sql, InfluxDBContants.APP_ALARM);
QueryResult result = inluxDBSingle.getInfluxDBByName(InfluxDBContants.AWS).getInfluxDB().query(query);
QueryResult result = inluxDBSingle.getInfluxDBByName(InfluxDBContants.ALARM).getInfluxDB().query(query);
return QueryResultUtil.getCount(result);
}
... ...