(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210909041.7 (22)申请日 2022.07.29 (71)申请人 天翼云科技有限公司 地址 100007 北京市东城区青龙胡同甲1 号、 3号2幢2层20 5-32室 (72)发明人 林佩航　任正国　关雨晗　 (74)专利代理 机构 北京三聚阳光知识产权代理 有限公司 1 1250 专利代理师 熊飞雪 (51)Int.Cl. G06F 16/25(2019.01) G06F 16/27(2019.01) G06F 16/242(2019.01) G06F 16/2457(2019.01) G06F 11/34(2006.01) (54)发明名称 数据库的数据分发处理方法及 装置、 存储介 质、 处理器 (57)摘要 本申请公开了一种数据库的数据分发处理 方法及装置、 存储介质、 处理器。 该方法包括： 响 应目标数据库中目标数据的订阅请求， 获取所述 目标数据库的目标日志， 其中， 所述目标日志为 记录所述目标数据的日志； 根据所述目标日志， 确定所述目标数据的数据内容； 根据预设格式对 所述数据内容进行类型转换， 得到分发数据， 其 中， 所述预设格式为所述订阅请求对应的目标对 象可用的数据格式； 响应所述订阅请求将所述分 发数据发送给对应的目标对象。 解决了相关技术 中postgreSQL数据库在进行数据分发时， 只能输 出SQL语句， 无法应用于异构数据库或其他的存 储介质的问题。 权利要求书2页 说明书10页 附图4页 CN 115455092 A 2022.12.09 CN 115455092 A 1.一种数据库的数据分发处 理方法， 其特 征在于， 包括： 响应目标数据库中目标数据的订阅请求， 获取所述目标数据库的目标 日志， 其中， 所述 目标日志为记录所述目标 数据的日志； 根据所述目标日志， 确定所述目标 数据的数据内容； 根据预设格式对所述数据内容进行类型转换， 得到分发数据， 其中， 所述预设格式为所 述订阅请求对应的目标对象可用的数据格式； 响应所述 订阅请求将所述分发数据发送给对应的目标对象。 2.根据权利要求1所述的方法， 其特征在于， 响应目标数据库中目标数据的订阅请求， 获取所述目标 数据库的目标日志包括： 接收对所述目标数据库的目标数据的订阅请求， 其中， 所述订阅请求包括所述目标数 据的时间起 点； 对所述目标数据库的日志进行查找， 确定所述日志中早于所述 时间起点且最靠近所述 时间起点的头事 件； 根据所述头事件获取所述日志中， 包括所述时间起点的目标事务的日志， 作为所述目 标日志， 其中， 所述目标事务包括多个事 件， 所述头事 件为所述目标事务中的第一个事 件。 3.根据权利要求2所述的方法， 其特征在于， 根据所述目标日志， 确定所述目标数据的 数据内容包括： 确定所述头事 件在所述日志中的标识； 根据所述标识作为复制起 点， 创建逻辑复制流， 通过解码插 件读取所述目标日志； 对所述目标日志进行解析， 得到所述目标数据的第 一数据内容， 其中， 所述第 一数据内 容包括下列至少之一： 事 件或事务变更 前后的数据信息， 事 件或事务的起止位置； 将所述第一数据内容作为所述数据内容。 4.根据权利要求3所述的方法， 其特征在于， 根据所述标识作为复制起点， 创建逻辑复 制流， 通过解码插 件读取所述目标日志之后， 所述方法还 包括： 对所述日志或所述第一数据内容进行处理， 得到对应的第 二数据内容， 其中， 所述第二 数据内容包括： 主键 字段标记； 根据所述第一数据内容和所述第二数据内容， 确定所述数据内容。 5.根据权利要求1所述的方法， 其特征在于， 根据 预设格式对所述数据内容进行类型转 换， 得到分发数据包括： 根据预设的映射关系， 对所述数据内容中不同的数据项转换为不同的预设格式， 得到 不同数据项在对应的预设格式上的数据面 值； 根据所述预设格式和所述数据面值构建数据条， 其中， 每个数据条至少包括一个数据 项的数据面 值和对应的预设格式； 将所述不同数据项的数据条封装为数据包， 作为所述分发数据。 6.根据权利要求5所述的方法， 其特征在于， 将所述不同数据项的数据条封装为数据 包， 作为所述分发数据包括： 将所述数据内容中所有的数据项， 按照所属事务进行分组， 得到多个事务分组， 其中， 每组的数据项的所属事务 为同一个事务； 对每个事务分组单独进行打包， 生成对应的事务数据包， 其中， 所述事务为所述数据分权　利　要　求　书 1/2 页 2 CN 115455092 A 2发的最小单位； 将至少一个数据包 共同作为分发数据。 7.根据权利要求1至6中任一项所述的方法， 其特征在于， 所述订阅请求对应的目标对 象为多个。 8.一种数据库的数据分发处 理装置， 其特 征在于， 包括： 获取模块， 用于响应目标数据库中目标数据的订阅请求， 获取所述目标数据库的目标 日志， 其中， 所述目标日志为记录所述目标 数据的日志； 确定模块， 用于根据所述目标日志， 确定所述目标 数据的数据内容； 转换模块， 用于根据预设格式对所述数据内容进行类型转换， 得到分发数据， 其中， 所 述预设格式为所述 订阅请求对应的目标对象可用的数据格式； 发送模块， 用于响应所述 订阅请求将所述分发数据发送给对应的目标对象。 9.一种计算机可读存储介质， 其特征在于， 所述存储介质用于存储程序， 其中， 所述程 序执行权利要求1至7中任意 一项所述的数据库的数据分发处 理方法。 10.一种电子设备， 其特征在于， 包括一个或多个处理器和存储器， 所述存储器用于存 储一个或多个程序， 其中， 当所述一个或多个程序被所述一个或多个处理器执行时， 使得所 述一个或多个处 理器实现权利要求1至7中任意 一项所述的数据库的数据分发处 理方法。权　利　要　求　书 2/2 页 3 CN 115455092 A 3