(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211310739.3 (22)申请日 2022.10.25 (71)申请人 税友信息技 术有限公司 地址 310053 浙江省杭州市滨江区浦沿街 道南环路3738号 (72)发明人 黄岭林　吴辰阳　岑浩铭　王伟　 吕勇　 (74)专利代理 机构 北京集佳知识产权代理有限 公司 11227 专利代理师 吴娟 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/25(2019.01) G06F 16/21(2019.01) (54)发明名称 一种DTS数据链路运维方法、 装置、 设备及介 质 (57)摘要 本申请公开了一种DTS数据链路运维方法、 装置、 设备及介质， 涉及信息技术领域。 该方法包 括： 获取DTS数据中针对目标端与源端的数据链 路的目标操作请求， 并获取所述目标端与所述源 端对应的目标yaml配置文件； 读取所述目标yaml 配置文件并得到所述目标yaml配置文件中的目 标数据信息， 然后根据所述目标操作请求对应的 目标操作选择与所述目标操作对应的预设目标 应用程序接口； 基于所述目标数据信息并调用所 述预设目标应用程序接口进行目标操作， 以完成 所述目标操作请求。 通过上述方案， 能够在进行 DTS数据链路运维时进行对多同步链路的批量操 作以提高DTS数据链路运维效率。 权利要求书2页 说明书9页 附图4页 CN 115495529 A 2022.12.20 CN 115495529 A 1.一种DTS数据链路运维方法， 其特 征在于， 包括： 获取DTS数据中针对目标端与源端的数据链路的目标操作请求， 并获取所述目标端与 所述源端对应的目标yaml配置文件； 读取所述目标yaml配置文件并得到所述目标yaml配置文件中的目标数据信息， 然后根 据所述目标操作请求对应的目标操作选择与所述目标操作对应的预设目标应用程序接口； 基于所述目标数据信 息并调用所述预设目标应用程序接口进行目标操作， 以完成所述 目标操作请求。 2.根据权利要求1所述的DTS数据链路运维方法， 其特征在于， 所述读取所述目标yaml 配置文件并得到所述目标yaml配置文件中的目标数据信息， 然后根据所述目标操作请求对 应的目标操作选择与所述目标操作对应的预设目标应用程序接口， 包括： 读取所述目标yaml配置文件并得到所述目标yaml配置文件中的数据链路ID清单、 数据 库和表的对应关系， 然后根据所述目标操作请求对应的目标同步链路创建操作选择与所述 目标同步链路创建操作对应的预设同步链路创建接口； 相应的， 所述基于所述目标数据信息并调用所述预设目标应用程序接口进行目标操 作， 以完成所述目标操作请求， 包括： 调用所述预设同步链路创建接口创建空 的同步链路， 并根据所述数据库和表的对应关 系配置所述同步链路， 以完成所述目标操作请求。 3.根据权利要求2所述的DTS数据链路运维方法， 其特征在于， 所述读取所述目标yaml 配置文件并得到所述目标yaml配置文件中的所述数据链路ID、 数据库和表的对应关系， 包 括： 读取所述目标yaml配置文件并得到所述目标yaml配置文件中的目标关键字段获取数 据库与表的对应关系， 然后根据所述目标关键 字段确定数据链路ID的命名方式； 根据所述数据链路ID的命名方式确定所述源端的数据源类型； 如果所述源端的数据源类型为DRDS数据源， 则通过DRDS的预设开放接口获取数据链路 ID清单； 如果所述源端的数据源类型为非DRDS数据源， 则直接从所述目标关键字段获取数 据链路ID清单。 4.根据权利要求1所述的DTS数据链路运维方法， 其特征在于， 所述读取所述目标yaml 配置文件并得到所述目标yaml配置文件中的目标数据信息， 然后根据所述目标操作请求对 应的目标操作选择与所述目标操作对应的预设目标应用程序接口， 包括： 读取所述目标yaml配置文件并得到所述目标yaml配置文件中的同步链路ID清单， 然后 根据所述目标操作请求对应的目标操作选择与所述目标操作对应的预设目标应用程序接 口； 相应的， 所述基于所述目标数据信息并调用所述预设目标应用程序接口进行目标操 作， 以完成所述目标操作请求， 包括： 获取待操作同步链路清单并通过DTS链路名称模糊匹配确定所述同步链路ID清单中的 待操作同步链路ID清单， 调用所述预设目标应用程序接口对 所述待操作同步链路ID清单中 的同步链路进行目标操作。 5.根据权利要求1所述的DTS数据链路运维方法， 其特征在于， 所述读取所述目标yaml 配置文件并得到所述目标yaml配置文件中的目标数据信息， 然后根据所述目标操作请求对权　利　要　求　书 1/2 页 2 CN 115495529 A 2应的目标操作选择与所述目标操作对应的预设目标应用程序接口， 包括： 读取所述目标yaml配置文件并得到所述目标yaml配置文件中的源端数据与目标端数 据的连接信息， 然后根据所述目标操作请求对应的目标数据校验操作选择与所述目标数据 校验操作对应的预设数据校验接口； 相应的， 所述基于所述目标数据信息并调用所述预设目标应用程序接口进行目标操 作， 以完成所述目标操作请求， 包括： 基于所述源端数据与所述目标端数据的连接信息根据所述源端数据与所述目标端数 据的数据类型组装查询语句获取源端数据量与目标端数据量； 调用预设数据 校验接口比较所述源端数据量与 所述目标端数据量的数据量差值， 以完 成所述目标 数据校验操作。 6.根据权利要求5所述的DTS数据链路运维方法， 其特征在于， 所述调用预设数据校验 接口比较所述源端数据量与所述目标端数据量的数据量差值之后， 还 包括： 如果所述数据量差值超过 预设数据量差值阈值， 则停止校验并进行告警； 如果所述数据量差值不超过预设数据量差值阈值， 则 检查当前是否已完成校验 并禁止 告警。 7.根据权利要求1至 6中任一项所述的DTS数据链路运维方法， 其特 征在于， 还 包括： 获取针对DTS数据的数据链路巡检请求， 并根据预设数据链路巡检接口对所有数据链 路进行状态巡检。 8.一种DTS数据链路运维装置， 其特 征在于， 包括： 请求获取模块， 用于获取DTS数据中针对目标端与源端的数据链路的目标操作请求， 并 获取所述目标端与所述源端对应的目标yaml配置文件； 配置文件解析模块， 用于读取所述目标yaml配置文件并得到所述目标yaml配置文件中 的目标数据信息， 然后根据所述目标操作请求对应的目标操作选择与所述目标操作对应的 预设目标应用程序接口； 接口调用模块， 用于基于所述目标数据信 息并调用所述预设目标应用程序接口进行目 标操作， 以完成所述目标操作请求。 9.一种电子设备， 其特 征在于， 包括： 存储器， 用于保存计算机程序； 处理器， 用于执行所述计算机程序， 以实现如权利要求1至7任一项所述的DTS数据链路 运维方法的步骤。 10.一种计算机可读存储介质， 其特征在于， 用于存储计算机程序； 其中， 所述计算机程 序被处理器执行时实现如权利要求1至7任一项所述的DTS数据链路运维方法的步骤。权　利　要　求　书 2/2 页 3 CN 115495529 A 3