版权所有:内蒙古大学图书馆 技术提供:维普资讯• 智图
内蒙古自治区呼和浩特市赛罕区大学西街235号 邮编: 010021
专利申请号:CN202110680049.6
公 开 号:CN113505106A
代 理 人:周庆佳
代理机构:11825 北京中仟知识产权代理事务所(普通合伙)
专利类型:发明专利
申 请 日:20211015
公 开 日:20210618
专利主分类号:G06F16/172(20190101)
关 键 词:引擎 写入 格式化处理 生产数据 原始数据 自动计算 离线 后台 架构 数据管理系统 格式化 分布式架构 分析处理 后台计算 数据存储 数据计算 写入数据 业务系统 用户体验 多路径 数据量 调用 服务器 前台 采集 压缩
摘 要:本发明提供数据管理系统后台自动计算引擎的设计,涉及MDM后台计算引擎领域。该MDM后台自动计算引擎的设计,采用spark与hadoop分布式架构相结合的技术来处理大规模的数据计算,包括如下具体实施步骤:生产数据的一方往kafka内生产数据;离线架构采用flume去采集kafka中的数据到hdfs中;实时架构采用sparkstreaming消费kafka中的数据,对原始数据进行格式化处理,将数据写入到hbase中;编写sql脚本把hdfs中的原始数据进行格式化处理,最后采用snappy压缩写入离线数仓hive中;对格式化的数据进行分析处理,然后将最终的结果写入到hbase内,供前台的业务系统调用。本发明相比之前的MDM系统,如今就算数据量再大,只需要增加服务器即可解决数据存储不下的问题,同时可以实现多路径写入数据,使得用户体验更好。