通过Spark Streaming进行设备日志监控报警及性能优化1、Spark Streaming进行设备监控及报警 ELK Stack:一整套开源的日志处理平台解决方案,可以集日志的采集、检索、可视化于一身,真正的处理现在的首选是Spark Streaming,中间件为Kafka用于做ELK和Spark Streaming之间的适配,关键的地方在于可以通过Spark Streaming中的.transform方法可以实现非常复杂的功能,而通过foreachRDD可以根据处理的结果发送邮件、短信、调用第三方平台或者报警系统等。 Transoform可触发Action |
|
来自: 看风景D人 > 《Spark学习总结》