(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 20221087469 2.7 (22)申请日 2022.07.25 (71)申请人 国家电网有限公司客户服 务中心 地址 300300 天津市东 丽区东丽湖丽湖环 路21号 (72)发明人 孙林檀　王岩　韩维　李瑞强　 孟月　张妍　金中超　 (74)专利代理 机构 天津万华知识产权代理事务 所(普通合伙) 12235 专利代理师 梁改改 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/23(2019.01) (54)发明名称 强隔离环境下 数据同步方法和相关 设备 (57)摘要 本申请提供一种强隔离环境下数据 同步方 法和相关设备， 包括： 通过Agent探针采集外网数 据， 并将采集的外网数据发送至外网APM系统中； 将位于外网APM系统中的外网数据构造为更新语 句， 并将更新语句发送至消息队列， 更新语句包 含语句生 成时的时间戳信息； 利用消费服务从消 息队列中获取更新语句； 通过内网强隔离数据库 接收并存储 更新语句； 利用内网的同步服务执行 时间戳信息符合预设条件的更新语句， 得到执行 后的外网数据； 将执行后的外网数据同步至内网 非关系型数据库中， 完成数据同步。 本申请在源 端和目标端均为非关系型数据库上的基础上， 构 造更新语句进行数据同步， 提高了数据同步速 度， 并扩大 数据同步方法的适用范围。 权利要求书2页 说明书8页 附图4页 CN 115422283 A 2022.12.02 CN 115422283 A 1.一种强隔离环境下 数据同步方法， 其特 征在于， 包括： 通过Agent探针采集外网数据， 并将采集的所述外网数据发送至 外网APM系统中； 将位于外网APM系统中的所述外网数据构造为更新语句， 并将所述更新语句发送至消 息队列， 所述更新语句包 含语句生成时的时间戳信息； 利用消费服 务从所述消息队列中获取 所述更新语句； 通过内网强隔离数据库接收并存 储所述更新语句； 利用内网的同步服务执行时间戳信 息符合预设条件的更新语句， 得到执行后的外网数 据； 将所述执 行后的外网数据同步至内网非关系型 数据库中， 完成数据同步。 2.根据权利要求1所述的强隔离环境下数据同步方法， 其特征在于， 将位于外网APM系 统中的所述外网数据构造为更新语句， 并将所述更新语句发送至消息队列， 所述更新语句 包含语句生成时的时间戳信息， 具体包括： 利用OAP后端将位于外网APM系统中的所述外网数据构造为更新语句， 并将所述外 网数 据存入外网APM系统内含的非关系型 数据库中； 利用OAP后端将所述更新语句发送至消息队列。 3.根据权利要求1所述的强隔离环境下数据同步方法， 其特征在于， 在所述利用消费服 务从所述消息队列中获取 所述更新语句后， 还 包括： 执行所述更新语句以得到执行后的外网数据， 并将该所述执行后的外网数据保存到外 网数据库中。 4.根据权利要求1所述的强隔离环境下数据同步方法， 其特征在于， 利用内网的同步服 务执行时间戳信息符合预设条件的更新语句， 得到执 行后的外网数据， 具体包括： 所述预设条件为预先设定的消费周期， 依据 所述时间戳信 息获取所述消费周期内对应 的所述更新语句； 对所述消费周期内的所述更新语句进行 执行， 得到所述执 行后的外网数据。 5.根据权利要求1所述的强隔离环境下数据同步方法， 其特征在于， 所述内网强隔离数 据库为MySQ L数据库、 Oracle 数据库或PostgreSQ L数据库。 6.根据权利要求3所述的强隔离环境下数据同步方法， 其特征在于， 所述外网数据库为 关系型数据库或非关系型 数据库。 7.根据权利要求1所述的强隔离环境下数据同步方法， 其特征在于， 所述内网非关系型 数据库还接收内网APM系统同步的内网数据， 并对所述内网数据与所述执行后的外网数据 进行融合计算和融合展示。 8.一种强隔离环境下 数据同步装置， 其特 征在于， 包括： 数据采集模块， 被配置为： 通过Agent探针采集外网数据， 并将采集的所述外网数据发 送至外网APM系统中； 数据转换模块， 被配置为： 将位于外网APM系 统中的所述外网数据构造为更新语句， 并 将所述更新语句发送至消息队列， 所述更新语句包 含语句生成时的时间戳信息； 语句获取模块， 被 配置为： 利用消费服 务从所述消息队列中获取 所述更新语句； 语句接收模块， 被 配置为： 通过内网强隔离数据库接收并存 储所述更新语句； 语句执行模块， 被配置为： 利用内网的同步服务执行时间戳信息符合预设条件的更新权　利　要　求　书 1/2 页 2 CN 115422283 A 2语句， 得到执 行后的外网数据； 数据同步模块， 被配置为： 将所述执行后的外网数据同步至内网非关系型数据库中， 完 成数据同步。 9.一种电子设备， 包括存储器、 处理器及存储在存储器上并可在处理器上运行的计算 机程序， 所述处 理器执行所述程序时实现如权利要求1至7任意 一项所述的方法。 10.一种非暂态计算机可读存储介质， 所述非暂态计算机可读存储介质存储计算机指 令， 所述计算机指令用于使计算机执 行权利要求1至7任意 一项所述的方法。权　利　要　求　书 2/2 页 3 CN 115422283 A 3