业务订单关联查询方法、装置、设备及存储介质.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113901078A(43)申请公布日2022.01.07(21)申请号202111366143.0(22)申请日2021.11.18(71)申请人平安普惠企业管理有限公司地址518027广东省深圳市前海深港合作区前湾一路1号A栋201室（入驻深圳市前海商务秘书有限公司）(72)发明人李响(74)专利代理机构北京市京大律师事务所11321代理人胡安(51)Int.Cl.G06F16/242(2019.01)G06F16/2455(2019.01)G06F16/27(2019.01)G06F16/28(2019.01)权利要求书3页说明书12页附图4页(54)发明名称业务订单关联查询方法、装置、设备及存储介质(57)摘要本发明涉及大数据技术领域，公开了一种业务订单关联查询方法、装置、设备及存储介质，用于提高跨数据源联合查询的业务订单处理效率。所述业务订单关联查询方法包括：从业务订单关联查询请求中提取业务订单结构化查询语句；通过预设中央协调组件将业务订单结构化查询语句转换成至少两个业务订单查询任务；按照各业务订单查询任务对应的任务类型，将各业务订单查询任务分发至对应的目标数据处理工作节点中；通过各目标数据处理工作节点对应的预设连接组件查询对应的预设数据源，得到业务订单关联查询数据，将业务订单关联查询数据返回至目标终端。此外，本发明还涉及区块链技术，业务订单关联查询数据可存储于区块链节点中。CN113901078ACN113901078A权利要求书1/3页1.一种业务订单关联查询方法，其特征在于，所述业务订单关联查询方法包括：获取目标终端发送的业务订单关联查询请求，从所述业务订单关联查询请求中提取业务订单结构化查询语句；通过预设中央协调组件对所述业务订单结构化查询语句进行语句解析和任务生成处理，得到至少两个业务订单查询任务，各业务订单查询任务具有对应的任务类型；按照各业务订单查询任务对应的任务类型，将各业务订单查询任务分发至对应的目标数据处理工作节点中；通过各目标数据处理工作节点对应的预设连接组件查询各业务订单查询任务对应的预设数据源，得到业务订单关联查询数据，并通过所述预设中央协调组件将所述业务订单关联查询数据返回至所述目标终端，所述预设数据源包括分布式数据库hbase和数据仓库hive。2.根据权利要求1所述的业务订单关联查询方法，其特征在于，所述获取目标终端发送的业务订单关联查询请求，从所述业务订单关联查询请求中提取业务订单结构化查询语句，包括：接收目标终端发送的业务订单关联查询请求，并对所述业务订单关联查询请求进行参数解析，得到参数解析数据；按照预设的参数验证规则对所述参数解析数据进行参数校验处理，得到参数校验结果；当所述参数校验结果为校验通过时，从所述参数解析数据中读取业务订单结构化查询语句，并将所述业务订单结构化查询语句存储至预设消息队列中。3.根据权利要求2所述的业务订单关联查询方法，其特征在于，所述通过预设中央协调组件对所述业务订单结构化查询语句进行语句解析和任务生成处理，得到至少两个业务订单查询任务，各业务订单查询任务具有对应的任务类型，包括：通过预设中央协调组件中的预置解析器对所述预设消息队列中的业务订单结构化查询语句进行语句分析和计划生成，得到业务订单查询逻辑计划，所述预设中央协调组件部署在预设分布式结构化查询语言执行引擎中；基于所述预设中央协调组件中的预置优化器对所述业务订单查询逻辑计划进行优化分割处理，得到至少两个业务订单查询任务，各业务订单查询任务具有对应的任务类型。4.根据权利要求1所述的业务订单关联查询方法，其特征在于，所述按照各业务订单查询任务对应的任务类型，将各业务订单查询任务分发至对应的目标数据处理工作节点中，包括：按照各业务订单查询任务对应的任务类型查询预设服务注册组件，得到各业务订单查询任务对应的多个数据处理工作节点；调用所述预设中央协调组件中的预置计算调度器对各业务订单查询任务对应的多个数据处理工作节点进行负载检测和心跳检测，得到各数据处理工作节点对应的负载状态和对应的心跳反馈数据；按照各业务订单查询任务对应的任务类型、各数据处理工作节点对应的负载状态和对应的心跳反馈数据，将各业务订单查询任务分发至对应的目标数据处理工作节点中，各目标数据处理工作节点用于指示心跳正常且网络负载小的数据处理工作节点。2CN113901078A权利要求书2/3页5.根据权利要求1所述的业务订单关联查询方法，其特征在于，所述通过各目标数据处理工作节点对应的预设连接组件查询各业务订单查询任务对应的预设数据源，得到业务订单关联查询数据，并通过所述预设中央协调组件将所述业务订单关联查询数据返回至所述目标终端，所述预设数据源包括分布式数据库hb