(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210216839.3 (22)申请日 2022.03.07 (71)申请人 内蒙古伊泰信息技 术有限公司 地址 017010 内蒙古自治区鄂 尔多斯市东 胜区高新技术产业园区高新大厦601 室 (72)发明人 王变宏　吕斌　包洪庭　胡少慧　 周立明　 (74)专利代理 机构 北京超凡宏宇专利代理事务 所(特殊普通 合伙) 11463 专利代理师 张萌 (51)Int.Cl. G06F 16/23(2019.01) G06F 16/27(2019.01) (54)发明名称 数据传输方法、 系统以及电子设备 (57)摘要 本申请提供了一种数据传输方法、 系统以及 电子设备， 涉及数据处理技术领域， 缓解了目标 系统的数据完整性较低的技术问题。 该方法包 括： 源系统的数据发送系统监测到源系统发生数 据变化事件时， 若根据数据变化事件对应的指定 源数据同步条件， 确定源数据需要同步， 则获取 源数据的参数信息， 基于参数信息生成待同步数 据包， 将待同步数据包发送至数据分发系统； 数 据分发系统基于待同步数据包中的参数信息重 新生成数据分发系统的数据包时间戳 以及数据 包唯一事务标识， 基于数据包时间戳以及数据包 唯一事务标识生成中间数据包， 向数据转换传输 系统发送中间数据包； 数据转换传输系统基于中 间数据包进行字段映射， 根据字段映射结果向目 标应用系统提交数据。 权利要求书3页 说明书16页 附图4页 CN 114579593 A 2022.06.03 CN 114579593 A 1.一种数据传输方法， 其特 征在于， 包括： 源系统的数据发送系统监测到所述源系统发生数据变化事件时， 若根据 所述数据变化 事件对应的指定源数据同步条件， 确定所述源数据需要同步， 则获取所述源数据的参数信 息， 基于所述参数信息生成待同步数据包， 并将所述待同步数据包发送至数据分发系统； 其 中， 所述参数信息包含所述数据变化事件的数据变动时间戳以及所述源数据的唯一编 码标 识； 所述数据分发系统基于所述待同步数据包中的所述参数信息重新生成所述数据分发 系统的数据包时间戳以及数据包唯一事务标识， 并基于所述数据包时间戳以及所述数据包 唯一事务标识生 成中间数据包， 向数据转换传输系统发送所述中间数据包； 其中， 所述数据 包时间戳和所述数据包唯一事务标识用于控制所述数据分发系统的分发数据权限； 所述数据转换传输系统基于所述中间数据包进行字段映射， 并根据字段映射结果向目 标应用系统提交数据。 2.根据权利要求1所述的方法， 其特征在于， 在所述数据发送系统将所述待同步数据包 发送至数据分发系统之后， 还 包括： 所述数据分发系统在接收到所述待同步数据包后向所述数据发送系统发送第一成功 反馈信息； 所述数据发送系统根据所述第一成功反馈信息将本地的所述待同步数据包删除 并记录同步日志； 或， 所述数据发送系统接收第 一失败反馈信 息， 并根据 所述第一失败反馈信 息更新本地的 所述待同步数据包的时间戳， 以启用延时同步机制。 3.根据权利要求1所述的方法， 其特征在于， 在所述数据分发系统向数据转换传输系统 发送所述中间数据包之后， 还 包括： 所述数据转换传输系统在接收到所述中间数据包后向所述数据分发系统发送第二成 功反馈信息； 所述数据分发系统根据所述第二成功反馈信息将本地的所述中间数据包删除 并记录同步日志； 或， 所述数据分发系统接收第 二失败反馈信 息， 并根据 所述第二失败反馈信 息更新本地的 所述中间数据包的时间戳， 以启用延时分发机制。 4.根据权利要求1所述的方法， 其特征在于， 所述数据发送系统包括数据同步配置规则 模块； 所述数据发送系统监测到所述源系统发生数据变化事 件时， 还包括： 通过所述数据同步配置规则模块确定所述数据变化事件对应的数据同步规则的配置 参数； 其中， 所述配置参数包括下述任意一项或多项： 所述源数据的类型、 所述源数据的对应 实体数据库 表、 所述源数据的唯一编码标识、 所述源数据同步条件、 所述源数据的数据变动 类型以及所述源数据的事务控制类型。 5.根据权利要求1所述的方法， 其特征在于， 所述参数信 息还包括： 所述源数据的类型、 所述源数据的数据变动类型、 所述源数据的对应实体数据库表、 所述源数据的事务控制类 型以及所述源数据同步条件； 所述基于所述 参数信息生成待同步数据包， 包括： 将所述源数据的类型和所述唯一编码标识解析至所述实体数据库表中的唯一标识字 段， 得到待传输实体数据库表； 组合所述待传输实体数据库表并组合所述参数信 息， 通过所述唯一标识字段转换数据权　利　要　求　书 1/3 页 2 CN 114579593 A 2获取条件， 基于所述数据获取 条件和组合结果 生成数据打包 命令； 根据所述事务控制类型判断并生成所述源系统唯一的事务控制ID标识， 对于所述源系 统的所述数据变化事件， 利用最新的数据内容和所述数据变动类型进行事务级别的排序， 对所述数据变化事件的多次操作按照所述事务控制ID标识的顺序进行同步， 得到同步结 果； 其中， 所述数据变化事 件包含数据产生、 修改和删除； 基于所述数据打包命令和所述同步结果生成待同步数据包， 对于所述待同步数据包的 同一条数据存在的多次并发修改， 按照所述事务控制ID标识和所述数据变动时间戳进行排 序， 并记录所述待同步数据包的日志。 6.根据权利要求1所述的方法， 其特征在于， 在所述数据分发系统向数据转换传输系统 发送所述中间数据包之前， 还 包括： 所述数据分发系统通过配置的数据分发规则 定义待分发系统， 并通过划分配置每个所 述待分发系统的分发参数， 针对每个所述待分发系统基于所述分发参数异 步通知所述中间 数据包的数据分发； 其中， 所述分发参数包括下述任意 一项或多 项： 所述待分发系统需要的数据类型、 同步数据权限规则、 数据变动类型、 事务控制类型、 同步数据模型以及唯一编码标识字段。 7.根据权利要求1所述的方法， 其特征在于， 所述数据转换传输系统基于所述中间数据 包进行字段映射， 并根据字段映射结果向目标应用系统提交数据， 包括： 所述数据转换传输系统通过配置应用系统的连接参数， 配置不同方式中的字段名称， 并根据接 收到的所述中间数据包按照所述连接参数、 协议方式、 函数及参数配置对所述字 段名称进行字段映射， 得到字段映射结果， 根据所述字段映射结果向目标应用系统提交数 据。 8.一种数据传输系统， 其特 征在于， 包括： 源系统的数据发送系统， 用于监测到所述源系统发生数据变化事件时， 若根据所述数 据变化事件对应的指定源数据同步条件， 确定所述源数据需要同步， 则获取所述源数据的 参数信息， 基于所述参数信息生成待同步数据包， 并将所述待同步数据包发送至数据分发 系统； 其中， 所述参数信息包含所述数据变化事件的数据变动时间戳以及所述源数据的唯 一编码标识； 所述数据分发系统， 用于基于所述待同步数据包中的所述参数信 息重新生成所述数据 分发系统的数据包时间戳以及数据包唯一事务标识， 并基于所述数据包时间戳以及所述数 据包唯一事务标识 生成中间数据包， 向数据转换传输系统发送所述中间数据包； 其中， 所述 数据包时间戳和所述数据包唯一事务标识用于控制所述数据分发系统的分发数据权限； 所述数据转换传输系统， 用于基于所述中间数据包进行字段映射， 并根据字段映射结 果向目标应用系统提交数据。 9.一种电子设备， 包括存储器、 处理器， 所述存储器中存储有可在所述处理器上运行的 计算机程序， 其特征在于， 所述处理器执行所述计算机程序时实现上述权利要求1至7任一 项所述的数据传输方法的步骤。 10.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质存储有计算机可 运行指令， 所述计算机可运行指令在被处理器调用和 运行时， 所述计算机可运行指令促使权　利　要　求　书 2/3 页 3 CN 114579593 A 3