关于Flink:Flink实时数仓数据采集层

56次阅读

共计 1387 个字符,预计需要花费 4 分钟才能阅读完成。

一、电商实时数仓介绍

1.1、一般实时计算与实时数仓比拟

  一般的实时计算 优先思考时效性,所以从数据源采集通过实时计算间接失去后果。如此做 时效性 更好,然而弊病是因为计算过程中的 两头后果没有积淀 下来,所以当面对大量实时需要的时候,计算的 复用性 较差,开发成本随着需要减少直线回升。

  实时数仓 基于肯定的数据仓库理念,对数据处理流程进行布局、分层,目标是进步数据的复用性。

1.2 实时电商数仓,我的项目分为以下几层

➢ ODS

  • 原始数据,日志和业务数据

➢ DWD

  • 依据数据对象为单位进行分流,比方订单、页面拜访等等

➢ DIM

  • 维度数据

➢ DWM

  • 对于局部数据对象进行进一步加工,比方独立拜访、跳出行为,也能够和维度进行关联,造成宽表,仍旧是明细数据。

➢ DWS

  • 依据某个主题将多个事实数据轻度聚合,造成主题宽表。

➢ ADS

  • 把 Clickhouse 中的数据依据可视化须要进行筛选聚合

二、实时需要概览

2.1 离线计算与实时计算的比拟

离线计算 :就是在计算开始前已知所有输出数据,输出数据不会产生变动,个别计算量级较大,计算工夫也较长。例如明天早上一点,把昨天累积的日志,计算出所需后果。最经典的就是 MR/Spark/Hive;
  个别是依据前一日的数据生成报表,尽管统计指标、报表繁多,然而对时效性不敏感。从技术操作的角度,这部分属于 批处理 的操作。即依据确定范畴的数据一次性计算。

实时计算 :输出数据是能够以序列化的形式一个个输出并进行解决的,也就是说在开始的时候并不需要晓得所有的输出数据。与离线计算相比,运行工夫短,计算量级绝对较小。强调计算过程的工夫要短,即所查当下给出后果。
  次要侧重于对当日数据的实时监控,通常业务逻辑绝对离线需要简略一下,统计指标也少一些,然而更重视数据的时效性,以及用户的交互性。从技术操作的角度,这部分属于 流解决 的操作。依据数据源源不断地达到进行实时的运算。

2.2 实时需要品种

2.2.1 日常统计报表或剖析图中须要蕴含当日局部

  对于日常企业、网站的经营治理如果仅仅依附离线计算,数据的 时效性 往往无奈满足。通过实时计算取得当日、分钟级、秒级甚至亚秒的数据更加便于企业对业务进行快速反应与调整。

  所以实时计算结果往往要与离线数据进行合并或者比照展现在 BI 或者统计平台中

2.2.2 实时数据大屏监控

  数据大屏,绝对于 BI 工具或者数据分析平台是更加直观的数据可视化形式。尤其是一些大促流动,曾经成为必备的一种营销伎俩。
  另外还有一些非凡行业,比方交通、电信的行业,那么大屏监控简直是必备的监控伎俩。

2.2.3 数据预警或提醒

  通过大数据实时计算失去的一些风控预警、营销信息提醒,可能疾速让风控或营销局部失去信息,以便采取各种应答。
  比方,用户在电商、金融平台中正在进行一些非法或欺诈类操作,那么大数据实时计算能够疾速的将状况筛选进去发送风控部门进行解决,甚至主动屏蔽。或者检测到用户的行为对于某些商品具备较强的购买志愿,那么能够把这些“商机”推送给客服部门,让客服进行被动的跟进。

2.2.4 实时举荐零碎

  实时举荐就是依据用户的本身属性联合以后的拜访行为,通过实时的举荐算法计算,从而将用户可能喜爱的商品、新闻、视频等推送给用户。
  这种零碎个别是由一个用户画像批处理加一个用户行为剖析的流解决组合而成。

三、统计架构剖析

3.1 离线架构

3.2、实时架构

关注我的公众号【宝哥大数据】,更多干货

正文完
 0