数据访问方法、系统和存储介质.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113761079A(43)申请公布日2021.12.07(21)申请号202110081569.5(22)申请日2021.01.21(71)申请人北京沃东天骏信息技术有限公司地址100176北京市大兴区北京经济技术开发区科创十一街18号院2号楼4层A402室申请人北京京东世纪贸易有限公司(72)发明人张伟(74)专利代理机构中国贸促会专利商标事务所有限公司11038代理人曹蓓许蓓(51)Int.Cl.G06F16/28(2019.01)G06F16/25(2019.01)权利要求书2页说明书10页附图7页(54)发明名称数据访问方法、系统和存储介质(57)摘要本公开提出一种数据访问方法、系统和存储介质，涉及数据库技术领域。本公开的一种数据访问系统，包括：数据平台，被配置为接收数据请求并发送至数据引擎；接收数据引擎反馈的请求执行结果；数据引擎，被配置为拆分数据请求，获取多个请求子任务，并将请求子任务发送给各个数据探针；汇总来自各个数据探针的子任务执行结果，生成请求执行结果，并反馈给数据平台；和多个数据探针，被配置为获取请求子任务；调用对应的数据节点执行请求子任务，生成子任务执行结果并反馈给数据引擎。这样的数据访问系统能够实现数据节点的无入侵访问，也无需数据同步操作，提高了数据请求的实时性，提高请求效率。CN113761079ACN113761079A权利要求书1/2页1.一种数据访问系统，包括：数据平台，被配置为接收数据请求并发送至数据引擎；接收所述数据引擎反馈的请求执行结果；数据引擎，被配置为拆分所述数据请求，获取多个请求子任务，并将所述请求子任务发送给各个数据探针；汇总来自各个数据探针的子任务执行结果，生成请求执行结果，并反馈给所述数据平台；和多个数据探针，被配置为获取所述请求子任务；调用对应的数据节点执行所述请求子任务，生成子任务执行结果，并将所述子任务执行结果反馈给所述数据引擎。2.根据权利要求1所述的系统，其中，所述数据探针为分布式部署，所述每个数据库的内网环境对应一个所述数据探针。3.根据权利要求1所述的系统，其中，所述数据平台或所述数据引擎中的至少一项为分布式集群部署。4.根据权利要求1所述的系统，其中，所述数据探针被配置为：接收来自所述数据节点的反馈数据；根据所述反馈数据，基于数据平台的数据模型生成所述子任务执行结果。5.根据权利要求1所述的系统，其中，所述数据引擎被配置为：将所述请求子任务的消息队列发布至子任务主题；所述数据探针被配置为：基于预设消息过滤规则，从所述子任务主题中过滤消息队列，获取属于自身的请求子任务。6.根据权利要求5所述的系统，其中，所述数据探针还被配置为将子任务执行结果发布至结果主题；所述数据引擎还被配置为：根据所述结果主题的消息队列，获取属于同一个数据请求的请求子任务的子任务执行结果；根据获取的子任务执行结果，聚合成符合所述数据平台的数据模型的请求执行结果。7.根据权利要求1～6任意一项所述的系统，其中，所述数据平台还被配置为执行以下至少一项：建立标准模型，并下发给所述数据引擎；生成各个数据探针与数据节点的对应关系，以及各个对应的数据节点的规则，并下发给与所述探针的对应关系；接收来自外部应用的数据请求；在收到来自所述数据引擎的请求执行结果后，将所述请求执行结果反馈给所述外部应用；或在收到所述数据请求后，执行数据请求校验；在校验通过的情况下，将所述数据请求发送至所述数据引擎。8.根据权利要求1～6任意一项所述的系统，其中，所述数据平台、所述数据引擎或所述数据探针中的至少一项为采用虚拟化方式部署。9.一种数据访问方法，包括：数据平台将数据请求发送至数据引擎；所述数据引擎拆分所述数据请求，获取多个请求子任务，并将所述请求子任务发送给2CN113761079A权利要求书2/2页各个数据探针；数据探针获取所述请求子任务，调用对应的数据节点执行所述请求子任务，生成子任务执行结果，并将所述子任务执行结果反馈给所述数据引擎；所述数据引擎汇总来自各个数据探针的子任务执行结果，生成请求执行结果，并反馈给所述数据平台。10.根据权利要求9所述的方法，其中，所述生成子任务执行结果包括：接收来自所述数据节点的反馈数据；根据所述反馈数据，基于数据平台的数据模型生成所述子任务执行结果。11.根据权利要求9所述的方法，其中，所述将所述请求子任务发送给各个数据探针包括：所述数据引擎将所述请求子任务的消息队列发布至子任务主题；所述数据探针获取所述请求子任务包括：所述数据探针基于预设消息过滤规则，从所述子任务主题中过滤消息队列，获取属于自身的请求子任务。12.根据权利要求11所述的方法，其中，所述将所述子任务执行结果反馈给所述数据引擎包括：所述数据