数据管理系统后台自动计算引擎的设计
基本信息
申请号 | CN202110680049.6 | 申请日 | - |
公开(公告)号 | CN113505106A | 公开(公告)日 | 2021-10-15 |
申请公布号 | CN113505106A | 申请公布日 | 2021-10-15 |
分类号 | G06F16/172(2019.01)I;G06F16/182(2019.01)I;G06F16/25(2019.01)I;G06F16/27(2019.01)I;G06F16/28(2019.01)I;G06F16/242(2019.01)I;G06F9/48(2006.01)I | 分类 | 计算;推算;计数; |
发明人 | 刘春华;向程;周华;陈华殷;王晓栋 | 申请(专利权)人 | 深圳弘星智联科技有限公司 |
代理机构 | 北京中仟知识产权代理事务所(普通合伙) | 代理人 | 周庆佳 |
地址 | 518000广东省深圳市龙岗区宝龙街道宝龙社区宝龙二路4号思达工业园办公楼208 | ||
法律状态 | - |
摘要
摘要 | 本发明提供数据管理系统后台自动计算引擎的设计,涉及MDM后台计算引擎领域。该MDM后台自动计算引擎的设计,采用spark与hadoop分布式架构相结合的技术来处理大规模的数据计算,包括如下具体实施步骤:生产数据的一方往kafka内生产数据;离线架构采用flume去采集kafka中的数据到hdfs中;实时架构采用sparkstreaming消费kafka中的数据,对原始数据进行格式化处理,将数据写入到hbase中;编写sql脚本把hdfs中的原始数据进行格式化处理,最后采用snappy压缩写入离线数仓hive中;对格式化的数据进行分析处理,然后将最终的结果写入到hbase内,供前台的业务系统调用。本发明相比之前的MDM系统,如今就算数据量再大,只需要增加服务器即可解决数据存储不下的问题,同时可以实现多路径写入数据,使得用户体验更好。 |
