来电科技:基于 Flink + Hologres 的实时数仓演进之路

本文涉及的产品
实时计算 Flink 版,5000CU*H 3个月
简介: 本文将会讲述共享充电宝开创企业来电科技如何基于 Flink + Hologres 构建统一数据服务加速的实时数仓

作者:陈健新,来电科技数据仓库开发工程师,目前专注于负责来电科技大数据平台离线和实时架构的整合。

GitHub 地址
https://github.com/apache/flink
欢迎大家给 Flink 点赞送 star~

深圳来电科技有限公司(以下简称 “来电科技”)是共享充电宝行业开创企业,主要业务覆盖充电宝自助租赁、定制商场导航机开发、广告展示设备及广告传播等服务。来电科技拥有业内立体化产品线,大中小机柜以及桌面型,目前全国超过 90% 的城市实现业务服务落地,注册用户超 2 亿人,实现全场景用户需求。

一、大数据平台介绍

1. 发展历程

来电科技大数据平台的发展历程主要分为以下三个阶段:

1)离散 0.X Greenplum

为什么说离散?因为之前没有一个统一的大数据平台来支持数据服务,而是由每个业务开发线自行取数或者做一些计算,并用一个低配版的 Greenplum 离线服务来维持日常的数据需求。

2)离线 1.0 EMR

之后架构升级为离线 1.0 EMR,这里的 EMR 指的是阿里云由大数据组成的弹性分布式混合集群服务,包括 Hadoop、HiveSpark 离线计算等常见组件。

阿里云 EMR 主要解决我们三个痛点:

  • 一是存储计算资源的水平可扩展;
  • 二是解决了前面各个业务线异构数据带来的开发维护问题,由平台统一清洗入仓;
  • 三是我们可以建立自己的数仓分层体系,划分一个主题域,为我们的指标系统打好基础。

3)实时、统一 2.0 Flink + Hologres

当前正经历的 “Flink + Hologres” 实时数仓,这也是本文分享的核心。它为我们大数据平台带来了两个质的改变,一是实时计算,二是统一数据服务。基于这两点,我们加速知识数据探索,促进业务快速发展。

2. 平台能力

总的概括来说,2.0 版本的大数据平台提供了以下能力:

  • 数据集成

    平台现在支持使用实时或者离线的方式集成业务数据库或业务数据的日志。

  • 数据开发

    平台现已支持基于 Spark 的离线计算以及基于 Flink 的实时计算。

  • 数据服务

    数据服务主要由两部分组成:

    • 一部分是由 Impala 提供的分析服务和即席分析的能力;
    • 另一部分是 Hologres 提供的针对业务数据的交互式分析能力。
  • 数据应用

    同时平台可以直接对接常见的 BI 工具,业务系统也能快速地集成对接。

image

3. 取得成就

大数据平台提供的能力给我们带来了不少成就,总结为以下五点:

  • 横向扩展

    大数据平台的核心就是分布式架构,这样我们能够低成本地水平扩展存储或者计算资源。

  • 资源共享

    可以整合所有服务器可用的资源。以前的架构是每个业务部门自己维护一套集群,这样会造成一些浪费,难以保证可靠性,而且运费成本较高,现在由平台统一调度。

  • 数据共享

    整合了业务部门所有的业务数据以及业务日志等其他异构数据源数据,由平台统一清洗对接。

  • 服务共享

    数据共享之后就由平台统一对外输出服务,各个业务线无需自行重复开发,就能快速得到平台提供的数据支撑。

  • 安全保障

    由平台提供统一的安全认证等授权机制,可以做到对不同人进行不同程度的细粒度授权,保证数据安全。

二、企业业务对数据方面的需求

随着业务的快速发展,构建统一的实时数仓迫在眉睫,综合 0.x、1.0 版本的平台架构,综合业务的现在发展和未来趋势判断,构建 2.x 版本数据平台的需求主要集中在以下几个方面:

  • 实时大屏

    实时大屏需要替换旧的准实时大屏,采用更可靠、低延迟的技术方案。

  • 统一数据服务

    高性能、高并发和高可用的数据服务成为企业数字化转型统一数据门户的关键,需要构建一个统一的数据门户,统一对外输出。

  • 实时数仓

    数据时效性在企业运营中的重要性日益凸现,需要响应更快更及时。

三、实时数仓和统一数据服务技术方案

1. 整体技术架构

技术架构主要分为四个部分,分别是数据 ETL、实时数仓、离线数仓和数据应用。

  • 数据 ETL 是对业务数据库和业务日志进行实时处理,统一使用 Flink 实时计算,
  • 实时数仓中数据实时处理后进入 Hologres 存储与分析
  • 业务冷数据存储在 Hive 离线数仓,并同步到 Hologres 做进一步的数据分析处理
  • 由 Hologres 统一对接常用的 BI 工具,如 Tableau、Quick BI、DataV 和业务系统等。

image

2. 实时数仓数据模型

如上所示,实时数仓和离线数仓有一些相似的地方,只不过少一些其它层的链路。

  • 第一层是原始数据层,数据来源有两种类型,一种是业务库的 Binlog,第二种是服务器的业务日志,统一用 Kafka 作为存储介质。
  • 第二层是数据明细层,将原始数据层 Kafka 里面的信息进行 ETL 提取,作为实时明细存储至 Kafka。这样做的目的是为了方便下游不同消费者同时订阅,同时方便后续应用层的使用。维表数据也是通过 Hologres 存储,来满足下面的数据关联或者条件过滤。
  • 第三是数据应用层,这里除了打通 Hologres,还使用了 Hologres 对接了 Hive,由 Hologres 统一提供上层应用服务。

3. 整体技术架构数据流

下面的数据流图可以具象加深整体架构的规划和数仓模型整体的数据流向。

从图中可以看出,主要分为三个模块:

  • 第一个是集成处理;
  • 第二个是实时数仓;
  • 第三块是数据应用。

从数据的流入流出看到主要的核心有两点:

  • 第一个核心是 Flink 的实时计算:可以从 Kafka 获取,或者直接 Flink cdt 读取 MySQL Binlog 数据,或者直接再写回 Kafka 集群,这是一个核心。
  • 第二个核心是统一数据服务:现在统一数据服务是由 Hologres 完成,避免数据孤岛产生的问题,或者一致性难以维护等,也加速了离线数据的分析。

image

四、具体实践细节

1. 大数据技术选型

方案执行分为两个部分:实时与服务分析。实时方面我们选择了阿里云 Flink 全托管的方式,它主要有以下几方面优点:

  • 状态管理与容错机制;
  • Table API 和 Flink SQL 支持;
  • 高吞吐低延迟;
  • Exactly Once 语义支持;
  • 流批一体;
  • 全托管等增值服务。

服务分析方面我们选择了阿里云 Hologres 交互式分析,它带来了几点好处:

  • 极速响应分析;
  • 高并发读写;
  • 计算存储分离;
  • 简单易用。

image

2. 实时大屏业务实践落地

image

上图为业务实时大屏新旧方案对比。

以订单为例,旧方案中的订单是从订单从库通过 DTS 同步到另一个数据库,这虽然是实时的,但是在计算与处理这方面,主要是通过定时任务,比如调度间隔时间设为 1 分钟或者 5 分钟来完成数据的实时更新,而销售层、管理层需要更实时地掌握业务动态,,因此并不能算真正意义上的实时。除此之外,响应慢且不稳定也是很大的问题。

新方案采用的是 Flink 实时计算 + Hologres 架构。

开发方式完全是可以利用 Flink 的 SQL 支持,对于我们之前的 MySQL 计算开发方式,可以说是一个无缝的迁移,实现快速落地。数据分析和服务统一使用 Hologres。还是以订单为例,比如今日订单营收额,今日订单用户数或者今日订单用户量,随着业务多样性的增加,可能需要增加城市维度。通过 Hologres 的分析能力,可以完美支撑营收额、订单量、订单用户数以及城市维度的一些指标做快速展示。

3. 实时数仓和统一数据服务实践落地

image

以某块业务场景为例,比如量级比较大的业务日志,日均数据量在 TB 级别。下面先来分析一下旧方案的痛点:

  • 数据时效性差:由于数据量较大,所以在旧方案中使用了每小时离线调度的策略进行数据计算。但是该方案时效性较差,无法满足众多业务产品的实时需求,例如硬件系统需要实时知道设备当前状态,如告警、错误、空仓等,以及时做出相应的决策行动。
  • 数据孤岛:旧方案使用 Tableau 对接大量业务报表,报表用于分析过去一个小时或者过去一天,设备上报有多少数量,哪些设备上报出现异常等。针对不同的场景,会将之前通过 Spark 离线计算的数据,再备份存储到 MySQL 或者 Redis 上。这样就多套系统,形成数据孤岛,这些数据孤岛对平台维护是一个巨大的挑战。

现在通过 2.0 Flink+Hologres 架构,可以将业务日志进行改造。

  • 以前 TB 级别的日志量在 Flink 高分子低延迟的计算框架下完全没有压力。例如之前的 flume HDFS 到 Spark 的一个链路直接被废弃,取而代之的是 Flink,我们只需要维护一个 Flink 的计算框架即可。
  • 设备状态数据采集的时候都是一些非结构的数据,需要对数据进行清洗,之后再返回 Kafka,因为消费者可能是多样化的,这样可以方便下游的多个消费者同时订阅。
  • 在刚才的场景中,硬件系统需要高并发、实时查询上千万的设备(充电宝)状态,对服务能力的要求较高。通过 Hologres 提供高并发读写能力,关联状态设备建立主键表,可以实时更新状态,满足 CRM 系统对设备(充电宝)的实时查询。
  • 同时在 Hologres 还会存最近的热点明细数据,直接提供对外服务。

4. 业务支撑效果

通过 Flink+Hologres 的新方案,我们支撑了三大场景:

  • 实时大屏

    业务层面更高效地迭代多样化需求,同时降低了开发、运维维护开销。

  • 统一数据服务

    通过一个 HSAP 系统来实现服务/分析一体化,避免数据孤岛以及一致性、安全性等问题。

  • 实时数仓

    满足企业运营中对于数据时效性越来越高的要求,秒级响应。

五、未来规划

伴随着业务的迭代,我们未来在大数据平台的规划主要有两点:流批一体和完善实时数仓。

  • 现在的大数据平台总的来说还是离线架构和实时架构混合,后续会废弃冗余的离线代码架构,借助 Flink 的流批一体统一计算引擎。
  • 另外,我们目前只迁移了部分业务,所以会参考之前已经完善的离线数仓指标系统体系,来满足我们现在的实时数仓建设,全面迁移到 2.0 Flink + Hologres 架构上。

通过未来的规划,我们希望同 Flink 全托管和 Hologres 一起共建更加完善的实时数仓,但也在此对其有着更近一步的需求:

1. 对 Flink 全托管的需求

Flink 全托管中的 SQL 编辑器编写 FlinkSQL 作业很高效方便,并且也提供了很多常见的 SQL 上下游 Connector 满足开发需求。但是仍有一些需求希望Flink全托管在后续的迭代中支持:

  • SQL 作业版本控制和兼容性监测;
  • SQL 作业支持 Hive3.X 集成;
  • DataStream 作业打包更方便、资源包上传速度更快;
  • Session 集群模式部署的任务支持自动调优功能。

2. 对 Hologres 交互式分析的需求

Hologres 不仅能够支持高并发地实时写入和查询,并且兼容 PostgreSQL 生态,方便接入使用统一数据服务。但是仍有一些需求希望 Hologres 能在后期迭代中支持:

  • 支持热升级操作,减少对业务的影响;
  • 支持数据表备份、支持读写分离;
  • 支持加速查询阿里云 EMR-Hive 数仓;
  • 支持对用户组进行计算资源管理。

更多 Flink 相关技术交流,可扫码加入社区钉钉大群~

image.png

活动推荐

阿里云基于 Apache Flink 构建的企业级产品-实时计算Flink版现开启6月限时活动:
0元试用实时计算Flink版(包年包月、10CU)即可有机会获得 Flink 独家定制T恤;另包3个月及以上还有85折优惠!
了解活动详情:https://www.aliyun.com/product/bigdata/sc

image.png

相关实践学习
数据库实验室挑战任务-初级任务
本场景介绍如何开通属于你的免费云数据库,在RDS-MySQL中完成对学生成绩的详情查询,执行指定类型SQL。
阿里云云原生数据仓库AnalyticDB MySQL版 使用教程
云原生数据仓库AnalyticDB MySQL版是一种支持高并发低延时查询的新一代云原生数据仓库,高度兼容MySQL协议以及SQL:92、SQL:99、SQL:2003标准,可以对海量数据进行即时的多维分析透视和业务探索,快速构建企业云上数据仓库。 了解产品 https://www.aliyun.com/product/ApsaraDB/ads
相关文章
|
1天前
|
SQL 运维 关系型数据库
Flink+Hologres搭建实时数仓
该方案利用Flink和Hologres构建实时数仓,解决传统数仓中间层查询困难、数据不可复用和架构冗余的问题。Flink负责数据源接入和加工,将数据写入Hologres的ODS、DWD和DWS层。Hologres支持高效更新和查询,各层数据可直接服务,简化架构,提高效率。方案具备高性能(Flink与Hologres深度集成,支持实时写入查询)、高可用(主从实例确保服务稳定)和低运维(全链路Flink SQL,减少运维成本)优势。适用于实时报表、推荐系统和业务监控等场景。
19 4
|
2天前
|
Oracle 关系型数据库 MySQL
实时计算 Flink版操作报错合集之用CTAS从mysql同步数据到hologres,改了字段长度,报错提示需要全部重新同步如何解决
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
45 8
|
3天前
|
安全 Java 数据处理
实时计算 Flink版操作报错合集之hologres里报错:找不到字段如何解决
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
14 4
|
6天前
|
SQL 运维 Cloud Native
基于OceanBase+Flink CDC,云粒智慧实时数仓演进之路
本文讲述了其数据中台在传统数仓技术框架下做的一系列努力后,跨进 FlinkCDC 结合 OceanBase 的实时数仓演进过程。
228 2
 基于OceanBase+Flink CDC,云粒智慧实时数仓演进之路
|
6天前
|
SQL 存储 JSON
Flink+Paimon+Hologres 构建实时湖仓数据分析
本文整理自阿里云高级专家喻良,在 Flink Forward Asia 2023 主会场的分享。
|
6天前
|
存储 消息中间件 监控
基于 Hologres+Flink 的曹操出行实时数仓建设
本文主要介绍曹操出行实时计算负责人林震,基于 Hologres+Flink 的曹操出行实时数仓建设的解决方案分享。
109430 1
基于 Hologres+Flink 的曹操出行实时数仓建设
|
6天前
|
SQL 关系型数据库 MySQL
使用CTAS 把mysql 表同步数据 到hologres ,Flink有什么参数可以使hologres 的字段都小写吗?
使用CTAS 把mysql 表同步数据 到hologres ,Flink有什么参数可以使hologres 的字段都小写吗?
320 0
|
6天前
|
SQL 存储 JSON
Flink+Paimon+Hologres 构建实时湖仓数据分析
本文整理自阿里云高级专家喻良,在 Flink Forward Asia 2023 主会场的分享。
71653 4
Flink+Paimon+Hologres 构建实时湖仓数据分析
|
6天前
|
SQL 消息中间件 Kafka
flink问题之做实时数仓sql保证分topic区有序如何解决
Apache Flink是由Apache软件基金会开发的开源流处理框架,其核心是用Java和Scala编写的分布式流数据流引擎。本合集提供有关Apache Flink相关技术、使用技巧和最佳实践的资源。
717 3
|
6天前
|
存储 运维 监控
飞书深诺基于Flink+Hudi+Hologres的实时数据湖建设实践
通过对各个业务线实时需求的调研了解到,当前实时数据处理场景是各个业务线基于Java服务独自处理的。各个业务线实时能力不能复用且存在计算资源的扩展性问题,而且实时处理的时效已不能满足业务需求。鉴于当前大数据团队数据架构主要解决离线场景,无法承接更多实时业务,因此我们需要重新设计整合,从架构合理性,复用性以及开发运维成本出发,建设一套通用的大数据实时数仓链路。本次实时数仓建设将以游戏运营业务为典型场景进行方案设计,综合业务时效性、资源成本和数仓开发运维成本等考虑,我们最终决定基于Flink + Hudi + Hologres来构建阿里云云原生实时湖仓,并在此文中探讨实时数据架构的具体落地实践。
飞书深诺基于Flink+Hudi+Hologres的实时数据湖建设实践

热门文章

最新文章

  • 1
    实时计算 Flink版操作报错合集之遇到报错:"An OperatorEvent from an OperatorCoordinator to a task was lost. Triggering task failover to ensure consistency." ,该怎么办
    15
  • 2
    实时计算 Flink版操作报错合集之在连接Oracle 19c时报错如何解决
    22
  • 3
    实时计算 Flink版操作报错合集之写入 Kafka 报错 "Failed to send data to Kafka: Failed to allocate memory within the configured max blocking time 60000 ms",该怎么解决
    13
  • 4
    实时计算 Flink版操作报错合集之报错显示“Unsupported SQL query! sqlUpdate() only accepts SQL statements of type INSERT and DELETE"是什么意思
    15
  • 5
    实时计算 Flink版操作报错合集之报错io.debezium.DebeziumException: The db history topic or its content is fully or partially missing. Please check database history topic configuration and re-execute the snapshot. 是什么原因
    14
  • 6
    实时计算 Flink版操作报错合集之本地打成jar包,运行报错,idea运行不报错,是什么导致的
    12
  • 7
    实时计算 Flink版操作报错合集之使用 Event Time Temporal Join 关联多个 HBase 后,Kafka 数据的某个字段变为 null 是什么原因导致的
    17
  • 8
    实时计算 Flink版操作报错合集之使用 Event Time Temporal Join 关联多个 HBase 后,Kafka 数据的某个字段变为 null 是什么原因导致的
    21
  • 9
    实时计算 Flink版操作报错合集之查询sqlserver ,全量阶段出现报错如何解决
    15
  • 10
    实时计算 Flink版操作报错合集之执行Flink job,报错“Could not execute SQL statement. Reason:org.apache.flink.table.api.ValidationException: One or more required options are missing”,该怎么办
    16
  • 相关产品

  • 实时计算 Flink版