(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 20221093861 1.5 (22)申请日 2022.08.05 (71)申请人 深圳市大头兄弟科技有限公司 地址 518000 广东省深圳市宝安区西乡街 道劳动社区西乡大道西侧海虹工业厂 区二期2栋9 ABCDE单位 (72)发明人 杨胜　 (74)专利代理 机构 深圳市特讯知识产权代理事 务所(普通 合伙) 44653 专利代理师 孟智广 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/23(2019.01) (54)发明名称 NoSQL数据库的同步方法、 装置、 设备及存储 介质 (57)摘要 本发明涉及数据库同步领域， 公开了一种 NoSQL数据库的同步方法、 装置、 设备及存储介 质。 该方法包括： MongoDB数据系统接收存储数 据， 在MongoDB数据系统的主节点存储存储数据； 基于主节 点接收数据同步指令， 分析数据同步指 令中的MongoDB数据名称、 链 接地址、 同步操作字 段、 同步数据类型； 调用预置Oplog组件， 复制 MongoDB数据名称、 链接地址、 同步操作字段、 同 步数据类型， 利用Oplog组件发送同步请求至 Elasticsearch集群系统； Elasticsearch集群系 统接收同步请求， 获取Oplog组件中的MongoDB数 据名称、 链接地址、 同步字段、 同步数据类型； 访 问链接地址对应主节点， 查询MongoDB数据名称 对应的目标存储 数据， 根据同步操作字段和同步 数据类型， 对目标存 储数据进行同步处 理。 权利要求书2页 说明书9页 附图2页 CN 115455113 A 2022.12.09 CN 115455113 A 1.一种NoSQL数据库的同步方法， 其特征在于， 所述NoSQL数据库的同步方法应用于 NoSQL数据库的同步系统， 所述NoSQL数据库的同步系统包括： MongoDB数据系统、 Elasticsearc h集群系统， 所述 NoSQL数据库的同步方法包括： 所述MongoDB数据系统接收存储数据， 在 所述MongoDB数据系统的主节点存储所述存储 数据； 基于所述主节点接收数据同步指令， 分析所述数据同步指令中的MongoDB 数据名称、 链 接地址、 同步操作字段、 同步数据类型； 调用预置Oplog组件， 复制 所述MongoDB数据名称、 所述链接地址、 所述同步操作字段、 所述同步数据类型， 利用所述Oplog组件发送同步请求至所述Elasticsearch集群系统， 其 中， 所述Opl og组件为Mo ngoDB数据系统中的集成组件； 所述Elasticsearch集群系统接收同步请求， 获取所述Oplog组件中的所述MongoDB数 据名称、 所述链接地址、 所述同步字段、 所述同步数据类型； 访问所述链接地址对应所述主节点， 查询所述MongoDB 数据名称对应的目标存储数据， 根据所述同步操作字段和所述同步数据类型， 对所述 目标存储数据进行同步处理， 以便实 现所述Elasticsearc h集群系统与Mo ngoDB数据系统的数据同步。 2.根据权利要求1所述的NoSQL数据库的同步方法， 其特征在于， 所述根据所述同步操 作字段和所述同步数据类型， 对所述目标存 储数据进行同步处 理包括： 若同步操作字段为删除操作字段， 则根据所述同步数据类型对应的删除指令， 对所述 Elasticsearc h集群系统的目标存 储数据、 所述主节点的目标存 储数据进行删除处 理； 若同步操作字段为复制操作字段， 则根据所述同步数据类型对应的复制指令， 将所述 主节点的目标存 储数据复制进入所述Elasticsearc h集群系统中。 3.根据权利要求2所述的NoSQL数据库的同步方法， 其特征在于， 所述根据所述同步数 据类型对应的复制指令， 将所述主节点的目标存储数据进入所述Elasticsearch集群系统 中包括： 根据所述同步数据类型对应的复制指令， 将所述主节点的目标存储数据复制， 黏贴至 所述Elasticsearc h集群系统中所述同步数据类型对应的分布 节点。 4.根据权利要求1所述的NoSQL数据库的同步方法， 其特征在于， 所述根据所述同步操 作字段和所述同步数据类型， 对所述目标存 储数据进行同步处 理包括： 若所述同步操作字段不为预置操作字段， 则终止同步进程， 将报错信息发送至所述 MongoDB数据系统中。 5.根据权利要求1所述的NoSQL数据库的同步方法， 其特征在于， 在所述根据所述同步 操作字段和所述同步数据类型， 对所述目标存 储数据进行同步处 理之后， 还 包括： 所述Elasticsearc h集群系统更新内部索引数据， 以便快速查询目标存 储数据。 6.根据权利要求1所述的NoSQL数据库的同步方法， 其特征在于， 所述访问所述链接地 址对应所述主节点包括： 判断所述链接地址是否属于所述主节点； 若属于， 则根据所述链接地址， 建立与所述主节点的通信连接； 若不属于， 则将 报错信息发送至所述Mo ngoDB数据系统中。 7.根据权利 要求1所述的NoSQL数据库的同步方法， 其特征在于， 所述查询所述MongoDB权　利　要　求　书 1/2 页 2 CN 115455113 A 2数据名称对应的目标存 储数据包括： 根据所述MongoDB数据名称， 检索所述主节点的数据， 得到所述MongoDB数据名称匹配 的存储数据； 将所述所述Mo ngoDB数据名称匹配的存 储数据确认为目标存 储数据。 8.一种NoSQL数据库的同步装置， 其特 征在于， 所述 NoSQL数据库的同步系统包括： MongoDB数据系统、 Elasticsearc h集群系统； 所述MongoDB数据系统， 用于接收存储数据， 在所述MongoDB数据系统的主节点存储所 述存储数据； 基于所述主节点接收数据同步指令， 分析所述数据同步指令中的MongoDB 数据名称、 链 接地址、 同步操作字段、 同步数据类型； 调用预置Oplog组件， 复制 所述MongoDB数据名称、 所述链接地址、 所述同步操作字段、 所述同步数据类型， 利用所述Oplog组件发送同步请求至所述Elasticsearch集群系统， 其 中， 所述Opl og组件为Mo ngoDB数据系统中的集成组件； 所述Elasticsearch集群系统， 用于接收同步请求， 获取所述Oplog组件中的所述 MongoDB数据名称、 所述链接地址、 所述同步字段、 所述同步数据类型； 访问所述链接地址对应所述主节点， 查询所述MongoDB 数据名称对应的目标存储数据， 根据所述同步操作字段和所述同步数据类型， 对所述 目标存储数据进行同步处理， 以便实 现所述Elasticsearc h集群系统与Mo ngoDB数据系统的数据同步。 9.一种NoSQL数据库的同步设备， 其特征在于， 所述NoSQL数据库的同步设备包括： 存储 器和至少一个处理器， 所述存储器中存储有指令， 所述存储器和所述至少一个处理器通过 线路互连； 所述至少一个处理器调用所述存储器中的所述指令， 以使得所述NoSQL数据库的同步 设备执行如权利要求1 ‑7中任一项所述的N oSQL数据库的同步方法。 10.一种计算机可读存储介质， 所述计算机可读存储介质上存储有计算机程序， 其特征 在于， 所述计算机程序被处理器执行时实现如权利要求 1‑7中任一项 所述的NoSQL数据库的 同步方法。权　利　要　求　书 2/2 页 3 CN 115455113 A 3