Apache Flink 和 Paimon 在自如数据集成场景中的使用

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
实时计算 Flink 版,5000CU*H 3个月
简介: Apache Flink 和 Paimon 在自如数据集成场景中的使用

业务背景


自如目前线上有基于 Hive 的离线数仓和基于 Flink、Kafka 的实时数仓,随着业务发展,我们也在探索引入湖仓一体的架构更好的支持业务,我们对比了 Iceberg、Hudi、Paimon 后,最终选择 Paimon 作为我们湖仓一体的存储引擎,本文分享下自如在引入 Paimon 做数据集成的一些探索实践。

一、原始接入


自如目前使用的业务库入 hive 的简略逻辑图如下(拿 Mysql 举例)

通过 hive jdbc handler 每天一个快照拉取数据到 hive,如果需要更高新鲜度的业务场景,使用 canal 把数据接入 kafka,然后通过 flink 写入 hdfs,再通过 hive merge 方式合并获得最高 10 分钟延迟新鲜度的数据。这个架构运行起来有几个问题:

  1. 基于 hive jdbc handler 拉取数据每天都是一个全量业务库数据,表比较大的情况下,对业务库压力比较大,如果增量拉取也需要业务线增加 lastmodified 字段,业务不见得愿意配合修改,分库分表场景支持起来也比较繁琐
  2. 基于 canal 的准实时线由于链路比较长,出现问题后也比较难排查

引入 paimon 之后数据接入的简略逻辑图如下

在整合 paimon 到大数据平台后,我们对数据接入流程进行了很大简化。具体来说,hive ods 层的数据来源已经从原来的原始业务表迁移到了 paimon 表。在我们的T+1离线分析场景中,仍然使用 hive ods 表;而对于需要实时数据的场景,则直接查询paimon 表。这种做法的一个显著优点是,夜间的批处理作业不再因为从原始业务数据库拉取数据而遭受延误。我们还向社区贡献了 “mongo入paimon” 的实现方案,以支持 mongodb 数据源到paimon的数据同步https://cwiki.apache.org/confluence/display/PAIMON/PIP-7%3A+SyncAction+based+on+MongoDB尽管paimon提供了显著的效率提升,但我们仍然保持使用 hive ods 表,而没有直接以 paimon 表替代它们。主要原因包括:查询语法的一致性:为了确保上层查询逻辑不受影响,我们需要维持 paimon 的标签(tag)查询和 Hive 的分区查询在语法上的一致性。这样做可以避免对现有大量 ETL任务进行修改。历史数据的动态路由:在查询 paimon 的标签时,如果数据属于历史的 hive 分区数据,我们还需要实现一个动态路由机制,以确保查询能够正确地指向这些历史数据。为了进一步优化这个流程,我们计划在未来和社区一起解决上述两个问题。这将进一步简化数据架构,提供更加灵活和高效的数据查询能力。

二、打宽接入


paimon 中的数据接入直接打宽的实现使我们比较感兴趣的,但是 paimon 中目前只支持主键打宽,不支持外键打宽,实际业务场景中很多都涉及外键打宽,对于这个场景我们做了自己的一个实现, 外键打宽涉及的核心问题是主外键关系的存储,我们把这个关系存储到外置的存储(比如 redis 或者 Mysql)中。举例来说宽表构建逻辑如下:

如上图  A、B、C 三张表需要打宽按照主键m 进行打宽,A、B两张表都有主键m,但是C没有,C表和B表用n字段关联。


如上图,如果A表或者B表中来了一条数据,直接在flink中 lookup join 关联A、B、C三张表,写入到下游宽表中(paimon 或者 clickhouse)。 如上图所示,如果C表来了一条数据,需要从B表和C表的关系表中,查询到C表这条数据的变更涉及到多少主键m的变更,然后把影响到的主键m值全部重新再关联一遍写入到下游表。



如上图所示,实际业务场景中是A、B、C三张表都会发生变化,就需要把所有表的变化影响到多少主键m变更都记录下来,并且重新关联写入下游宽表,相当于进行一个“暴力计算”。这里我们用的是 flink lookup join,  A、B、C都是维表,那 flink lookup join 的流表是哪个?其实这里我们构建了一个“虚拟流表”,这个流表只有一个字段就是主键m, A、B、C表的任何变更,涉及到多少的主键m的变更,都实时写入到这个虚拟流表中,这个虚拟流表可以用 kafka 或者 paimon 作为载体实现。
简单的逻辑如上面所述,实际真正使用的时候还会涉及业务的A、B、C源表并不能直接lookup join,还需要构建对应的镜像表、构建外键索引表。具体的代码实现可以看下面的全部基于mysql实现的简化版本的一个例子https://github.com/CNDPP/widetable/tree/main 代码中的例子是三张mysql表按照bus_opp_num字段打宽写入一张mysql表,从这个简化例子可以了解具体实现的细节。

三、下一步规划


1、原始表接入中使用 paimon tag 替换掉目前的 hive 分区,减少 hdfs 空间占用

2、paimon 社区规划中也有支持外键打宽的规划,跟随社区引入测试使用

3、把 paimon 引入到后续的数仓 ETL 加工之中,利用湖上的 zorder 等特性加速离线跑批在落地 paimon 实践的过程中,深切的感受到了 paimon 社区的活跃和热情,之信老师给我们非常多的耐心指导,帮助我们在生产环境中快速落地,感谢 paimon 社区,祝福 paimon 越来越好!

相关实践学习
AnalyticDB MySQL海量数据秒级分析体验
快速上手AnalyticDB MySQL,玩转SQL开发等功能!本教程介绍如何在AnalyticDB MySQL中,一键加载内置数据集,并基于自动生成的查询脚本,运行复杂查询语句,秒级生成查询结果。
阿里云云原生数据仓库AnalyticDB MySQL版 使用教程
云原生数据仓库AnalyticDB MySQL版是一种支持高并发低延时查询的新一代云原生数据仓库,高度兼容MySQL协议以及SQL:92、SQL:99、SQL:2003标准,可以对海量数据进行即时的多维分析透视和业务探索,快速构建企业云上数据仓库。 了解产品 https://www.aliyun.com/product/ApsaraDB/ads
相关文章
|
13天前
|
存储 人工智能 大数据
The Past, Present and Future of Apache Flink
本文整理自阿里云开源大数据负责人王峰(莫问)在 Flink Forward Asia 2024 上海站主论坛开场的分享,今年正值 Flink 开源项目诞生的第 10 周年,借此时机,王峰回顾了 Flink 在过去 10 年的发展历程以及 Flink社区当前最新的技术成果,最后展望下一个十年 Flink 路向何方。
297 33
The Past, Present and Future of Apache Flink
|
1月前
|
分布式计算 大数据 Apache
ClickHouse与大数据生态集成:Spark & Flink 实战
【10月更文挑战第26天】在当今这个数据爆炸的时代,能够高效地处理和分析海量数据成为了企业和组织提升竞争力的关键。作为一款高性能的列式数据库系统,ClickHouse 在大数据分析领域展现出了卓越的能力。然而,为了充分利用ClickHouse的优势,将其与现有的大数据处理框架(如Apache Spark和Apache Flink)进行集成变得尤为重要。本文将从我个人的角度出发,探讨如何通过这些技术的结合,实现对大规模数据的实时处理和分析。
142 2
ClickHouse与大数据生态集成:Spark & Flink 实战
|
2月前
|
SQL Java API
Apache Flink 2.0-preview released
Apache Flink 社区正积极筹备 Flink 2.0 的发布,这是自 Flink 1.0 发布以来的首个重大更新。Flink 2.0 将引入多项激动人心的功能和改进,包括存算分离状态管理、物化表、批作业自适应执行等,同时也包含了一些不兼容的变更。目前提供的预览版旨在让用户提前尝试新功能并收集反馈,但不建议在生产环境中使用。
851 13
Apache Flink 2.0-preview released
|
2月前
|
存储 缓存 算法
分布式锁服务深度解析:以Apache Flink的Checkpointing机制为例
【10月更文挑战第7天】在分布式系统中,多个进程或节点可能需要同时访问和操作共享资源。为了确保数据的一致性和系统的稳定性,我们需要一种机制来协调这些进程或节点的访问,避免并发冲突和竞态条件。分布式锁服务正是为此而生的一种解决方案。它通过在网络环境中实现锁机制,确保同一时间只有一个进程或节点能够访问和操作共享资源。
92 3
|
1月前
|
存储 数据挖掘 数据处理
巴别时代使用 Apache Paimon 构建 Streaming Lakehouse 的实践
随着数据湖技术的发展,企业纷纷探索其优化潜力。本文分享了巴别时代使用 Apache Paimon 构建 Streaming Lakehouse 的实践。Paimon 支持流式和批处理,提供高性能、统一的数据访问和流批一体的优势。通过示例代码和实践经验,展示了如何高效处理实时数据,解决了数据一致性和故障恢复等挑战。
122 61
|
26天前
|
消息中间件 Java Kafka
什么是Apache Kafka?如何将其与Spring Boot集成?
什么是Apache Kafka?如何将其与Spring Boot集成?
63 5
|
28天前
|
消息中间件 Java Kafka
Spring Boot 与 Apache Kafka 集成详解:构建高效消息驱动应用
Spring Boot 与 Apache Kafka 集成详解:构建高效消息驱动应用
43 1
|
1月前
|
SQL 存储 数据处理
兼顾高性能与低成本,浅析 Apache Doris 异步物化视图原理及典型场景
Apache Doris 物化视图进行了支持。**早期版本中,Doris 支持同步物化视图;从 2.1 版本开始,正式引入异步物化视图,[并在 3.0 版本中完善了这一功能](https://www.selectdb.com/blog/1058)。**
|
1月前
|
监控 Cloud Native BI
8+ 典型分析场景,25+ 标杆案例,Apache Doris 和 SelectDB 精选案例集(2024版)电子版上线
飞轮科技正式推出 Apache Doris 和 SelectDB 精选案例集 ——《走向现代化的数据仓库(2024 版)》,汇聚了来自各行各业的成功案例与实践经验。该书以行业为划分标准,辅以使用场景标签,旨在为读者提供一个高度整合、全面涵盖、分类清晰且易于查阅的学习资源库。
|
1月前
|
分布式计算 大数据 Apache
Apache Spark & Paimon Meetup · 北京站,助力 LakeHouse 架构生产落地
2024年11月15日13:30北京市朝阳区阿里中心-望京A座-05F,阿里云 EMR 技术团队联合 Apache Paimon 社区举办 Apache Spark & Paimon meetup,助力企业 LakeHouse 架构生产落地”线下 meetup,欢迎报名参加!
107 3

热门文章

最新文章

推荐镜像

更多