(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211172102.2 (22)申请日 2022.09.26 (71)申请人 北京信格科技有限公司 地址 100089 北京市海淀区农大南路1号院 2号楼3层办公B- 302 (72)发明人 肖云鹤　刘亚军　贺欢庆　代庆国　 (74)专利代理 机构 北京细软智谷知识产权代理 有限责任公司 1 1471 专利代理师 刘迪 (51)Int.Cl. G06F 16/242(2019.01) G06F 16/245(2019.01) G06F 16/2455(2019.01) (54)发明名称 一种异构数据聚合查询方法、 系统、 装置和 存储介质 (57)摘要 本发明涉及数据采集处理技术领域， 具体涉 及一种异构数据聚合查询方法、 系统、 装置和存 储介质， 首先， 通过数据过滤初筛到查询指令对 应的不同语句， 其次， 通过多线程的工作方式定 位到不同语句对应的数据库并执行得到查询结 果， 最后进行数据的聚合， 本发明在数据推送的 过程中， 后续的数据还可 以继续处理， 做到了及 时获推送， 提升了系统的运行速度， 避免了查找 数据过程中的轮询和排队现象。 权利要求书2页 说明书6页 附图2页 CN 115510083 A 2022.12.23 CN 115510083 A 1.一种异构数据聚合 查询方法， 其特 征在于， 包括： 接收用户输入的查询指令， 并将所述查询指令推送至数据过滤单元进行过滤， 得到查 询语句并标记； 其中， 所述 查询指令存在于异构数据中； 将标记后的查询语句输入到相应的解析器中， 所述解析器通过多线程的方式将标记后 的查询语句解析到对应的数据库并执行得到查询结果， 通过数据 汇聚器将所述查询结果汇 聚为同类型 数据； 输出查询指令对应的查询信息 。 2.根据权利要求1所述的方法， 其特 征在于， 还 包括： 对所述同类型 数据进行 再次过滤； 其中， 所述再次过 滤至少包括两次过 滤。 3.根据权利要求2所述的方法， 其特征在于， 所述将标记后的查询语句输入到相应的解 析器中， 包括： 将标记后的关系型 数据输入到关系型解析器； 或者， 将标记后的非关系型 数据输入到非关系型 数据解析器。 4.根据权利要求3所述的方法， 其特征在于， 所述解析器通过多线程的方式将标记后的 查询语句解析到对应的数据库， 包括： 将关系型 数据MySQ L语句解析到 MySQL数据库； 将Oracle语句解析到Oracle 数据库； 将postgres语句解析到postgres数据库； 或者， 将非关系型 数据Redis语句和Hbase解析为命令； 将ES语句解析到 ES数据库。 5.根据权利要求4所述的方法， 其特征在于， 所述通过数据汇聚器将所述查询结果汇聚 为同类型 数据， 具体为： 将关系型数据输出的结果集Resultset与非关系型数据输出的JSON数据汇聚为kafka 数据。 6.根据权利要求1 ‑5任意一项所述的装置， 其特征在于， 所述方法能够打包成JAR归档 文件， 作为S DK嵌入式供第三方 软件调用。 7.一种异构数据聚合 查询系统， 其特 征在于， 包括： 接收模块， 用于接收用户输入的查询指令， 并将所述查询指令推送至数据过滤单元进 行过滤， 得到查询语句并标记； 其中， 所述 查询指令存在于异构数据中； 汇聚模块， 用于将标记后的查询语句输入到相应的解析器中， 所述解析器通过多线程 的方式将标记后的查询语句解析到对应的数据库并执行得到查询结果， 通过数据 汇聚器将 所述查询结果汇聚为同类型 数据； 输出模块， 用于 输出查询指令对应的查询信息 。 8.根据权利要求7所述的系统， 其特征在于， 所述系统可以作为单独的归档文件， 以嵌 入的方式供第三方系统调用。 9.一种异构数据聚合 查询装置， 其特 征在于， 包括上述1 ‑6任意一项所述的方法。 10.一种计算机可读存 储介质， 其特 征在于， 其上存 储有可擦 写的计算机程序； 当所述计算机程序在计算机设备上运行时， 使得所述计算机设备执行如权利要求1 ‑6权　利　要　求　书 1/2 页 2 CN 115510083 A 2任意一项所述的方法。权　利　要　求　书 2/2 页 3 CN 115510083 A 3