一种实时数据治理的方法、设备、存储介质
实质审查的生效
摘要
本申请公开了一种实时数据治理的方法、设备、存储介质，该方法包括：将采集的数据放入消息队列的第一话题中，通过流式计算引擎的第一作业模块对所述第一话题中的数据进行数据清洗，根据固定的逻辑筛选后标记主题标签和时间戳；将所述标记主题标签和时间戳的数据存储到所述消息队列的第二话题中；通过流式计算引擎的第二作业模块将所述第二话题中的数据按照所述主题标签插入到主题数据库中；将所述主题数据库中的数据同步到预先搭建的Hive数据仓库中；通过流式计算引擎的第三作业模块根据所述Hive数据仓库中的数据生成数据血缘关系图谱。
基本信息
专利标题 ：
一种实时数据治理的方法、设备、存储介质
专利标题（英）：
暂无
公开（公告）号 ：
CN114265883A
申请号 ：
CN202111610777.6
公开（公告）日 ：
2022-04-01
申请日 ：
2021-12-27
授权号 ：
暂无
授权日 ：
暂无
发明人 ：
赵子墨罗森李照川孙永超李沅泽
申请人 ：
浪潮卓数大数据产业发展有限公司
申请人地址 ：
江苏省无锡市无锡经济开发区金融一街15号1101、1102、1103、1104、1105、1106、1107、1108
代理机构 ：
北京君慧知识产权代理事务所(普通合伙)
代理人 ：
肖鹏
优先权 ：
CN202111610777.6
主分类号 ：
G06F16/2458
IPC分类号 ：
G06F16/2458 G06F16/25 G06F16/28 G06F16/22 G06F16/215
IPC结构图谱
G
G部——物理
G06
计算；推算或计数
G06F
电数字数据处理
G06F16/2458
••••特殊类型的查询，例如统计查询、模糊查询或分布式查询
法律状态
2022-04-19 ：
实质审查的生效
IPC(主分类) : G06F 16/2458
申请日 : 20211227
申请日 : 20211227
2022-04-01 ：
公开
注：本法律状态信息仅供参考，即时准确的法律状态信息须到国家知识产权局办理专利登记簿副本。
文件下载
暂无PDF文件可下载
