本申请涉及一种分布式数据库数据同步的 监控方法及其相关设备，方法包括：在分布式数 据库数据同步过程中，获取第一SQL语句及预设 告警信息；对第一SQL语句进行解析，以得到第一 SQL语句对应的第一语句信息；根据第一语句信 息和预设告警信息，确定是否需对第一SQL语句 进行语句告警；在确定需要第一SQL语句进行语 句告警时，根据第一语句信息确定第一SQL语句 对应的目标告警策略；根据目标告警策略，对第 一SQL语句执行与目标告警策略对应的目标告警 操作。本申请减少了第一SQL语句执行失败对整 个数据同步过程的影响，提升了数据同步的效 率。
1.一种分布式数据库数据同步的监控方法，其特征在于，包括： 在分布式数据库数据同步过程中，获取第一SQL语句及预设告警信息； 对所述第一SQL语句进行解析，以得到所述第一SQL语句对应的第一语句信息； 根据所述第一语句信息和所述预设告警信息，确定是否需对所述第一SQL语句进行语 句告警； 在确定需对所述第一SQL语句进行语句告警时，根据所述第一语句信息确定所述第一 SQL语句对应的目标告警策略； 根据所述目标告警策略，对所述第一SQL语句执行与所述目标告警策略对应的目标告 警操作。
2.根据权利要求1所述的方法，其特征在于，所述在确定需对所述第一SQL语句进行语 句告警时，根据所述第一语句信息确定所述第一SQL语句对应的目标告警策略，包括： 在确定需对所述第一SQL语句进行语句告警时，获取所述第一SQL语句对应的预设告警 过滤条件； 根据所述第一语句信息确定所述第一SQL语句是否满足所述预设告警过滤条件； 在确定所述第一SQL语句满足预设告警过滤条件时，确定所述第一SQL语句对应的目标 告警策略为第一告警策略； 在确定所述第一SQL语句不满足所述预设告警过滤条件时，确定所述第一SQL语句对应 的目标告警策略为第二告警策略； 所述根据所述目标告警策略，对所述第一SQL语句执行与所述目标告警策略对应的目 标告警操作，包括： 在所述目标告警策略为所述第一告警策略时，对所述第一SQL语句不进行告警提示； 在所述目标告警策略为所述第二告警策略时，对所述第一SQL语句进行告警提示。
3.根据权利要求2所述的方法，其特征在于，在所述第一SQL语句为DDL语句时，所述第 一语句信息包括所述DDL语句对应的第一分片ID、所述DDL语句对应的第一库名及所述DDL 语句对应的第一表名； 所述预设告警过滤条件包括所述第一分片ID与第二SQL语句对应的分片ID一致、所述 第一库名与所述第二SQL语句对应的库名一致及所述第一表名与所述第二SQL语句对应的 表名一致，所述第二SQL语句用于指示已进行告警提示的SQL语句；或， 所述预设告警过滤条件包括所述第一库名属于预设库名集，和/或所述第一表名属于 预设表名集，所述预设库名集中的预设库名用于指示无需进行告警的库名，所述预设表名 集中的预设表名用于指示无需进行告警的表名。
4.根据权利要求2所述的方法，其特征在于，在所述第一SQL语句为DML语句时，所述第 一语句信息包括所述DML语句对应的第二表名； 所述在确定需对所述第一SQL语句进行语句告警时，获取所述第一SQL语句对应的预设 告警过滤条件，包括： 在确定需对所述第一SQL语句进行语句告警时，从所述预设告警信息中获取到进行语 句告警所对应的预设告警阈值； 确定所述第二表名对应的目标表中所出现的异常数据的目标数量； 在所述目标数量大于所述预设告警阈值时，获取所述第一SQL语句对应的预设告警过滤条件。
5.根据权利要求4所述的方法，其特征在于，在所述第一SQL语句为DML语句时，所述第 一语句信息还包括所述DML语句对应的第二分片ID和所述DML语句对应的第二库名； 所述预设告警过滤条件包括所述第二分片ID与第二SQL语句对应的分片ID一致、所述 第二库名与所述第二SQL语句对应的库名一致及所述第二表名与所述第二SQL语句对应的 表名一致，所述第二SQL语句用于指示已进行告警提示的SQL语句；或， 所述预设告警过滤条件包括所述第二库名属于预设库名集，和/或所述第二表名属于 预设表名集，所述预设库名集中的预设库名用于指示无需进行告警的库名，所述预设表名 集中的预设表名用于指示无需进行告警的表名。
6.根据权利要求2所述的方法，其特征在于，所述在所述目标告警策略为所述第二告警 策略时，对所述第一SQL语句进行告警提示，包括： 在所述目标告警策略为所述第二告警策略时，根据所述第一SQL语句对应的目标语句 类型，确定与所述目标语句类型对应的目标告警终端，所述目标语句类型包括DDL语句和 DML语句，所述目标告警终端用于指示对所述第一SQL语句进行告警提示的终端； 确定所述第一SQL语句对应的目标告警信息； 将所述目标告警信息推送至所述目标告警终端，以对所述第一SQL语句进行告警提示。
7.根据权利要求6所述的方法，其特征在于，在执行所述将所述目标告警信息推送至所 述目标告警终端，以对所述第一SQL语句进行告警提示步骤之后，所述方法，还包括： 接收所述目标告警终端发送的所述预设告警信息对应的目标反馈信息； 在所述目标反馈信息用于修正所述预设告警信息时，根据所述目标反馈信息对所述预 设告警信息进行修正，以完成所述预设告警信息的更新； 在完成所述预设告警信息的更新后，利用更新后的所述预设告警信息，执行所述在分 布式数据库数据同步过程中，获取第一SQL语句及预设告警信息步骤。
8.一种分布式数据库数据同步的监控装置，其特征在于，包括： 获取模块，用于在分布式数据库数据同步过程中，获取第一SQL语句及预设告警信息； 解析模块，用于对所述第一SQL语句进行解析，以得到所述第一SQL语句对应的第一语 句信息； 确定模块，用于根据所述第一语句信息和所述预设告警信息，确定是否需对所述第一 SQL语句进行语句告警； 所述确定模块，用于在确定需对所述第一SQL语句进行语句告警时，根据所述第一语句 信息确定所述第一SQL语句对应的目标告警策略； 告警模块，用于根据所述目标告警策略，对所述第一SQL语句执行与所述目标告警策略 对应的目标告警操作。
9.一种电子设备，其特征在于，包括：处理器和存储器，所述处理器用于执行所述存储 器中存储的分布式数据库数据同步的监控程序，以实现权利要求1～7中任一项所述的分布 式数据库数据同步的监控方法。
10.一种存储介质，其特征在于，所述存储介质存储有一个或者多个程序，所述一个或 者多个程序可被一个或者多个处理器执行，以实现权利要求1～7中任一项所述的分布式数 据库数据同步的监控方法。
