1 .一种异构数据库的数据同步监控系统,其特征在于,包括:采集模块、消息队列中间
件模块、管理监控模块,其中:
所述采集模块,用于采集并解析同步任务的白名单与源端数据库的元数据,获取需要
同步的表对象,解析源端数据库业务日志,获取表对象的数据变更信息;
所述消息队列中间件模块,用于以所述表对象为单位创建相应数量的信息管道,通过
每个信息管道接收所述采集模块推送的相应表对象的数据变更信息以进行数据回放;
所述管理监控模块,用于监控并管理指定信息管道的工作状态和工作进度,以控制对
应表对象的同步过程。
2 .根据权利要求1所述的异构数据库的数据同步监控系统,其特征在于,所述系统还包
括回放模块,用于接收所述消息队列中间件中各信息管道的可消费数据并回放至目标端数
据库。
3 .根据权利要求1所述的异构数据库的数据同步监控系统,其特征在于,所述系统还包
括下游抽数平台,用于所述消息队列中间件新建或复用信息管道,对指定表对象的变更数
据进行抽取。
4 .根据权利要求1所述的异构数据库的数据同步监控系统,其特征在于,所述系统包括
监控管理平台,用于下发指令给管理监控模块,以及接收所述管理监控模块上报的信息。
5 .根据权利要求1所述的异构数据库的数据同步监控系统,其特征在于,所述管理监控
模块包括管理单元和监控单元;
所述监控单元,用于监控所述消息队列中间件的信息管道的生产消费进度和消费数据
信息;
所述管理单元,用于控制消息队列中间件的信息管道中有序队列的生产消费。
6 .根据权利要求1所述的异构数据库的数据同步监控系统,其特征在于,所述消息队列
中间件接收所述表对象以有序队列的形式发送至指定信息管道的数据变更信息。
7 .根据权利要求1所述的异构数据库的数据同步监控系统,其特征在于,所述数据变更
信息包括数据位置、数据变更内容和变更时间。
8.一种基于如权利要求1所述的数据同步监控系统的数据同步监控方法,其特征在于,
包括:
采集并解析同步任务的白名单和源端数据库元文件,获取需要同步的表对象,并以所
述表对象为单位创建相应数量的信息管道;
将所述表对象的数据变更信息推送至所述消息队列中间件的信息管道;
监控并管理指定消息队列中间件中信息管道的工作状态和工作进度。
9 .一种非易失性计算机可读存储介质,其特征在于,所述非易失性计算机可读存储介
质存储有计算机可执行指令,该计算机可执行指令被一个或多个处理器执行时,可使得所
述一个或多个处理器执行权利要求1‑7任一项所述的异构数据库的数据同步监控方法。
权 利 要 求 书
1/1 页
2
文档被以下合辑收录
评论