FLINK中如何使用进行网站监控报警和报警恢复


这篇文章给大家介绍FLINK中如何使用进行网站监控报警和报警恢复,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。flink CEP 简介flink CEP(Complex event processing),是在Flink之上实现的复杂事件处理库,可以允许我们在不断的流式数据中通过我们自己定义的模式(Pattern)检测和获取出我们想要的数据,然后对这些数据进行下一步的处理。通过各种pattern的组合,我们可以定义出非常复杂的模式来匹配我们的数据。网上讲CEP原理和用法的文章很多,大家可以参考下 https://juejin.im/post/5de1f32af265da05cc3190f9#heading-9简单来说一下,其实我们可以把使用flink cep当做我们平时用的正则表达式,cep中的Pattern就是我们定义的正则表达式,flink中的DataStream就是正则表达式中待匹配的字符串,flink 通过DataStream 和 自定义的Pattern进行匹配,生成一个经过过滤之后的DataStream .基于自定义的pattern,我们可以做很多工作,比如监控报警、风控、反爬等等,接下来我们基于一个简单的报警小例子来讲解一些FLINK cep的实际应用。我们基于flink CEP做一个简单的报警,首先我们简化一下报警的需求
1.统计出来每秒钟http状态码为非200的数量所占比例。大于0.7的时候触发报警。
2.统计结果连续发生三大于阈值(0.7,这个数字是我自己写的,为了测试用,真实环境需要根据实际经验来设置)发送报警通知。
3.统计结果小于等于阈值触发报警恢复通知。实际应用中我们一般会去消费kafka的数据来作为source、这里我们为了简化,通过自定义source生成一些模拟的数据。接下来我们定义一个sql,用来计算我们的需求中的第一个要求。通过执行sql,我们获取到了一个Resu 香港云主机lt对象的DataStream,接下来我们到了最核心的地方,我们需要定一个Pattern。来详细解释一下这个Pattern在我们获得了相应的报警和恢复之后,接下来就是调用报警接口进行处理了,我们这只是简单的打印出来信息。关于FLINK中如何使用进行网站监控报警和报警恢复就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。

相关推荐: Django中怎么请求HTML页面视图信息

Django中怎么请求HTML页面视图信息,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。应用目录 下的 views.py 文件通常用于保存响应各种请求的函数或类文件目录结构如下:编写相关页面代码编…

免责声明:本站发布的图片视频文字,以转载和分享为主,文章观点不代表本站立场,本站不承担相关法律责任;如果涉及侵权请联系邮箱:360163164@qq.com举报,并提供相关证据,经查实将立刻删除涉嫌侵权内容。

(0)
打赏 微信扫一扫 微信扫一扫
上一篇 08/14 12:57
下一篇 08/14 12:58

相关推荐