标签:内容 日志格式 环境 sts adt 客户 ati range last
A系统与B系统之间有很多接口交互,但是有一段时间接口经常报错,作为开发如果不能第一时间知道问题且及时解决的话就会收到业务投诉,当月绩效凉凉。
如果你也有这种场景,那么你就需要一个及时告警的功能。
实现及时告警分以下两种场景:
~~很简单,搭建一个日志收集环境(O(∩_∩)O哈哈~)~~
需要在业务代码中嵌入硬编码,每次catch到异常直接发送告警信息告警平台进行告警
最核心的是 elasticsearch组件,所有的告警方案前提条件都是告警日志需要进ES,然后定时从ES中检索出符合业务规定的告警日志(比如ERROR日志),如果检索出来的告警日志满足一定条件就触发告警通知。
实现方式主要有以下几种:
ES WATCHER
这个是elasticsearch的官方插件,它可以根据数据的变化提供警报和通知,目前是收费的,具体操作配置可以参看官方地址
elastalert
是Yelp公司基于python写的告警框架,大家可以去GitHub上查看具体使用方法。elastalert
自定义开发
主要由以下几个步骤实现:
public class AlarmLog {
/**日志级别*/
private String logLevel;
/**日志描述*/
private String message;
/**关联主键 一般使用requestId*/
private String refCode;
/**请求参数*/
private String parm;
/**响应数据*/
private String response;
/**开发模块,根据此参数配置模块负责人*/
private String module;
/**日志时间*/
private long logTime;
...
}
public List<LogDoc> findRangeLogByLevel(DateTime minRange, DateTime maxRange, String logLevel) {
//需要强制转换成小写
logLevel = logLevel.toLowerCase();
SearchQuery searchQuery = new NativeSearchQueryBuilder()
.withQuery(boolQuery()
//module 必须有值才能告警
.must(existsQuery("module"))
.must(termQuery("logLevel", logLevel))
.must(rangeQuery("logTime")
.from(minRange.getMillis())
.to(maxRange.getMillis())))
.build();
return elasticsearchTemplate.queryForList(searchQuery, LogDoc.class);
}
标签:内容 日志格式 环境 sts adt 客户 ati range last
原文地址:https://www.cnblogs.com/jianzh5/p/11624394.html