专业网站建设品牌,十四年专业建站经验,服务6000+客户--广州京杭网络
免费热线:400-683-0016      微信咨询  |  联系我们

mysql查询延时,实时数据仓库如何做_数据库

当前位置:网站建设 > 技术支持
资料来源:网络整理       时间:2023/3/5 12:38:41       共计:3585 浏览
mysql查询延时,实时数据仓库如何做?

3.1.1 Lambda架构

来自Apache Flink 中文学习网站 ververica.cn 侵权告知立删

3.1.2 Kappa架构

来自Apache Flink 中文学习网站 ververica.cn 侵权告知立删

3.1.3 实时olap变体架构

来自Apache Flink 中文学习网站 ververica.cn 侵权告知立删

3.1.4 常见架构对比

来自Apache Flink 中文学习网站 ververica.cn 侵权告知立删

ps:lambda架构

开发割裂感:

? 表结构不同

? sql语法不同

资源浪费:

? 重复计算

? 重复存储

集群维护:

? 组件不同

? 计算引擎不同

数据一致性

3.2 实时数仓架构

3.2.1 方案一

优点:

? 便于数据回溯、重算和数据质量验证。

缺点:

? 通过批处理重算,需要维护两套代码,开发和维护成本高。

? 需要两套计算资源

适用场景:

? 超大规模历史数据计算,且这种场景比较频繁。

? 对数据质量要求极高,需要比对实时和离线的计算结果,甚至利用离线去修正实时的计算结果。

3.2.2 方案二

优点:

? 无需维护两套代码,开发迭代速度快。

? 数据回溯和重算方便,重算时间根据需求回溯的时间范围定。

? 只需流计算资源,资源占用小

缺点:

? ODS\DWD部分数据“不可见”,原始数据和中间数据不便于查询(解决方案:可通过重新消费指定时间范围的数据查询,或导入需要的数据到olap引擎)

? 依赖业务端反馈问题(解决方案:设计数据质量监控指标,实时监控报警)

适用场景:

ODS\DWD查询不频繁等

3.2.3 方案三

相对于方案二:

? 增加ODS层落地hive,排查分析原始数据比较方便,恢复历史数据的时候可获取hive数据写入kafka,然后按原流处理的逻辑重新处理即可,只需修改数据源为历史数据对应的topic。

? 需新增kafka写入hive逻辑

? 需新增从hive读取数据写入kafka

? 需新增整条链路历史数据对应的topic

版权说明:
本网站凡注明“广州京杭 原创”的皆为本站原创文章,如需转载请注明出处!
本网转载皆注明出处,遵循行业规范,如发现作品内容版权或其它问题的,请与我们联系处理!
欢迎扫描右侧微信二维码与我们联系。
·上一条:mysql查询多层,关于互联网编程语言_数据库 | ·下一条:查询出mysql,怎么查看mysql数据库的用户名和密码_数据库

Copyright © 广州京杭网络科技有限公司 2005-2024 版权所有    粤ICP备16019765号 

广州京杭网络科技有限公司 版权所有