Authored by qinchao

influxdb配置增加一个:Ip 10.66.80.43 influx 库名 app_collect_sample

... ... @@ -43,7 +43,13 @@ public class SingleTask implements Runnable {
}
}
//获取数据
if("app".equals(taskModel.getInfluxdbs())&&taskModel.getDatabase().equals("app_collect_sample")){
logger.error("beginqqqqq "+taskModel.getInfluxSql());
}
Map<String, List<List<Map<String, Object>>>> result = getResult(taskModel);
if("app".equals(taskModel.getInfluxdbs())&&taskModel.getDatabase().equals("app_collect_sample")){
logger.error("afterquery"+result);
}
taskSheduleMapper.updateLastTime(id);//更新时间
//按照告警类型进行处理
if(30==taskModel.getAlarmType()||31==taskModel.getAlarmType()||32==taskModel.getAlarmType()||33==taskModel.getAlarmType()){
... ...