中电工业互联网有限公司刘洋获国家专利权
买专利卖专利找龙图腾,真高效! 查专利查商标用IPTOP,全免费!专利年费监控用IP管家,真方便!
龙图腾网获悉中电工业互联网有限公司申请的专利多源异构实时数据处理方法、系统、设备和介质获国家发明授权专利权,本发明授权专利权由国家知识产权局授予,授权公告号为:CN117290453B 。
龙图腾网通过国家知识产权局官网在2025-10-10发布的发明授权授权公告中获悉:该发明授权的专利申请号/专利号为:202311243964.4,技术领域涉及:G06F16/28;该发明授权多源异构实时数据处理方法、系统、设备和介质是由刘洋;曹林;涂平;梁春峰;张林宇;贺群雄;刘准;仇亚龙;贺若龙;李志超;彭中益;王斯政;廖佳佳;刘博;罗超;金剑设计研发完成,并于2023-09-25向国家知识产权局提交的专利申请。
本多源异构实时数据处理方法、系统、设备和介质在说明书摘要公布了:本申请涉及多源异构实时数据处理方法、系统、设备和介质,该方法通过实时数据表处理实现数据处理在多个环节上一体化,最终完成整个实时数据处理的全部过程,解决了多源异构实时数据的统一管理与控制难题,解决了因处理流程繁多而数据开发杂乱的难题,同时也降低人工成本且简化系统开发流程。相比于传统技术,上述方案制定了统一的数据处理标准模型,简化数据处理逻辑,降低系统架构复杂度;采用临时表的内存数据处理,大大的提高了实时数据处理速度和开发效率;兼容多种异构数据类型,兼容多种源系统,解决数据孤岛、沉淀数据资产;模块插件数据开发,对不同数据类型和规则处理需求具备灵活性与扩展性。
本发明授权多源异构实时数据处理方法、系统、设备和介质在权利要求书中公布了:1.一种多源异构实时数据处理方法,其特征在于,包括步骤: 在异构数据源的数据源管理页面中添加各实时数据源、配置数据源连接信息并完成连通性测试; 在规则配置管理页面中添加各数据处理规则并保存至规则配置表;所述数据处理规则包括协议解析规则、SQL处理规则、数据过滤规则、维度关联规则、主键去重规则、指标聚合规则和数据结构规则; 基于DAG界面操作创建与编辑Flink的DAG实时处理画布并保存至画布表;在所述DAG实时处理画布中基于DAG拖拉拽动态选择数据处理插件,所述数据处理插件包括Flink输入插件、Flink转换插件和Flink输出插件; 在所述DAG实时处理画布中,采用Flink实时数据处理构建模型将整个实时数据处理过程进行模块划分;划分的模块包括Flink输入表处理模块、Flink转换表处理模块、Flink输出表处理模块和Flink数据存储处理模块; 在所述DAG实时处理画布中,选择Flink输入插件并配置输入表,选择Flink转换插件并配置转换规则,选择Flink输出插件并配置输出表和存储表; 在所述实时数据处理过程中,基于Flink内部临时表注册模型将模块中数据表注册为临时表对象; 在所述实时数据处理过程中,采用Flink实时数据流转换模型从各模块插件已注册的临时表对象中获取实时数据流; 在所述实时数据处理过程中,采用数据表配置建模模型对各模块插件中的数据表配置进行数据建模并定义建模特征; 在Flink输入表处理模块中,设置Flink输入临时表构建过程并采用基于临时表注册模型对输入表进行临时表注册; 在Flink转换表处理模块中,设置Flink转换临时表构建过程并采用基于临时表注册模型对转换表进行临时表注册; 在Flink输出表处理模块中,设置Flink输出临时表构建过程并采用基于临时表注册模型对输出表进行临时表注册; 在Flink数据存储处理模块中,设置Flink存储临时表构建过程并采用基于临时表注册模型对存储表进行临时表注册; 在Flink数据存储处理模块中,采用Flink实时数据同步模型执行外部存储介质的实时数据同步过程,最终完成整个实时数据处理过程。
如需购买、转让、实施、许可或投资类似专利技术,可联系本专利的申请人或专利权人中电工业互联网有限公司,其通讯地址为:410000 湖南省长沙市长沙高新开发区尖山路39号长沙中电软件园一期10栋801;或者联系龙图腾网官方客服,联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。
以上内容由龙图腾AI智能生成。
1、本报告根据公开、合法渠道获得相关数据和信息,力求客观、公正,但并不保证数据的最终完整性和准确性。
2、报告中的分析和结论仅反映本公司于发布本报告当日的职业理解,仅供参考使用,不能作为本公司承担任何法律责任的依据或者凭证。

皖公网安备 34010402703815号
请提出您的宝贵建议,有机会获取IP积分或其他奖励