海量监控日志基于EMR Spark Streaming SQL进行实时聚合

伯箫 2019-08-05

监控 TableStore SQL 日志 日志服务 SLS spark ots EMR 表格存储 流计算 sparkstreaming loghub StreamCompute 聚合

前言

从EMR-3.21.0 版本开始将提供Spark Streaming SQL的预览版功能,支持使用SQL来开发流式分析作业。结果数据可以实时写入Tablestore。
本文以LogHub为数据源,收集ECS上的日志数据,通过Spark Streaming SQL进行聚合后,将流计算结果数据实时写入Tablestore,展示一个简单的日志监控场景。
image

场景设计

假设有一个商品表Goods,商品信息开放给用户浏览,用户浏览完以后会产生以下格式的日志数据:

{
  "RequestId":"c85df119-f6db-449f-89bb-6773d2468f89",
  "Time":2019-07-30 12:05:28,
  "GoodsName":"shoes",
  "OperationType":"query"
}

我们需要将原始日志

登录 后评论
下一篇
冒顿单于
9013人浏览
2019-08-28
相关推荐
通过Spark SQL实时归档SLS数据
1356人浏览
2019-06-17 11:28:02
EMR Druid 探索(一)
1805人浏览
2018-06-01 17:46:23
阿里云 EMR最佳实践和容灾
1637人浏览
2018-05-15 11:06:37
2
2
1
3893