检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
选择目标端需要同步到的Topic。 投送到kafka的数据格式 选择投送到kafka的数据格式。 Avro:可以显示Avro二进制编码,高效获取数据。 Json:为Json消息格式。 详细格式可参考Kafka消息格式。 同步对象 左侧框是源数据库对象,右侧框是已经选择的对象,同步对
DBCOMPATIBILITY 'mysql'; 同步前检查 在创建任务前,需要针对同步条件进行手工自检,以确保您的同步任务更加顺畅。 在同步前,您需要参考入云使用须知获取同步相关说明。 创建DRS同步任务 本章节介绍创建DRS实例,将本地MySQL上的test_info数据库同步到GaussDB实例中tes
用于一个表一个Topic的场景。 投送到kafka的数据格式 选择投送到kafka的数据格式。 Avro:可以显示Avro二进制编码,高效获取数据。 JSON:为Json消息格式,方便解释格式,但需要占用更多的空间。 JSON-C:一种能够兼容多个批量,流式计算框架的数据格式。 详细格式可参考Kafka消息格式。
选择目标端需要同步到的Topic。 投送到kafka的数据格式 选择投送到kafka的数据格式。 Avro:可以显示Avro二进制编码,高效获取数据。 Json:为Json消息格式。 详细格式可参考Kafka消息格式。 同步对象 左侧框是源数据库对象,右侧框是已经选择的对象,同步对
增量同步的启动位点,格式为timestamp:incre(timestamp代表unix时间戳,单位为秒;incre代表当前命令在同一秒内执行的次序)。同步任务从启动位点开始获取源库增量日志(含当前启动位点)。 副本集通过db.getSiblingDB("local").oplog.rs.find();命令查看源库
如果不启用SSL安全连接,请自行承担数据安全风险。 图6 Kafka信息 表10 Kafka信息 参数 描述 IP地址或域名 Kafka的IP地址或域名。DRS从Kafka中获取TiDB产生的Binlog数据,然后将对应的增量更新实时同步至到目标库中 图7 目标库信息 表11 目标库信息 参数 描述 数据库实例名称
大于等于92556默认使用并行解码,复制槽名命名规则为“drs_唯一性标识”。其中唯一性标识需要将任务node id中的“-”替换为“_”获取,node id可在DRS任务同步日志页面查看“task node id is ***”日志找到。 操作步骤 在“实时同步管理”页面,单击“创建同步任务”。
个空格。 选择的同步对象名称中不能包含空格。 启动位点 步骤2的同步模式选择“增量”时可见,增量同步的启动位点,任务的源库日志从位点后开始获取(不含当前启动位点)。 若不指定,以当前数据库lsn位点启动(SQL Server为cdc.lsn_time_mapping系统表中 start_lsn列
个空格。 选择的同步对象名称中不能包含空格。 启动位点 步骤2的同步模式选择“增量”时可见,增量同步的启动位点,任务的源库日志从位点后开始获取(不含当前启动位点)。 若不指定,以当前数据库lsn位点启动(SQL Server为cdc.lsn_time_mapping系统表中 start_lsn列
个空格。 选择的同步对象名称中不能包含空格。 启动位点 步骤2的同步模式选择“增量”时可见,增量同步的启动位点,任务的源库日志从位点后开始获取(不含当前启动位点)。 若不指定,以当前数据库lsn位点启动(SQL Server为cdc.lsn_time_mapping系统表中 start_lsn列
个空格。 选择的同步对象名称中不能包含空格。 启动位点 步骤2的同步模式选择“增量”时可见,增量同步的启动位点,任务的源库日志从位点后开始获取(不含当前启动位点)。 若不指定,以当前数据库lsn位点启动(SQL Server为cdc.lsn_time_mapping系统表中 start_lsn列
个空格。 选择的同步对象名称中不能包含空格。 启动位点 步骤2的同步模式选择“增量”时可见,增量同步的启动位点,任务的源库日志从位点后开始获取(不含当前启动位点)。 若不指定,以当前数据库lsn位点启动(SQL Server为cdc.lsn_time_mapping系统表中 start_lsn列
大于等于92556默认使用并行解码,复制槽名命名规则为“drs_唯一性标识”。其中唯一性标识需要将任务node id中的“-”替换为“_”获取,node id可在DRS任务同步日志页面查看“task node id is ***”日志找到。 前提条件 已登录数据复制服务控制台。 账户余额大于等于0元。
大于等于92556默认使用并行解码,复制槽名命名规则为“drs_唯一性标识”。其中唯一性标识需要将任务node id中的“-”替换为“_”获取,node id可在DRS任务同步日志页面查看“task node id is ***”日志找到。 前提条件 已登录数据复制服务控制台。 账户余额大于等于0元。
大于等于92556默认使用并行解码,复制槽名命名规则为“drs_唯一性标识”。其中唯一性标识需要将任务node id中的“-”替换为“_”获取,node id可在DRS任务同步日志页面查看“task node id is ***”日志找到。 前提条件 已登录数据复制服务控制台。 账户余额大于等于0元。
强制结束任务章节的指导进行操作。 逻辑复制槽命名规则为“drs_唯一性标识”,其中唯一性标识需要将任务node id中的“-”替换为“_”获取。node id可在DRS任务同步日志页面查看task node id is ***日志找到。 操作步骤 在“实时同步管理”页面,单击“创建同步任务”。
_role参数值修改为原来的值。 逻辑复制槽命名规则为“drs_唯一性标识”,其中唯一性标识需要将任务node id中的“-”替换为“_”获取。node id可在DRS任务同步日志页面查看task node id is ***日志找到。 常见故障排查: 在任务创建、启动、全量同步
大于等于92556默认使用并行解码,复制槽名命名规则为“drs_唯一性标识”。其中唯一性标识需要将任务node id中的“-”替换为“_”获取,node id可在DRS任务同步日志页面查看“task node id is ***”日志找到。 操作步骤 在“实时同步管理”页面,单击“创建同步任务”。
强制结束任务章节的指导进行操作。 逻辑复制槽命名规则为“drs_唯一性标识”,其中唯一性标识需要将任务node id中的“-”替换为“_”获取。node id可在DRS任务同步日志页面查看task node id is ***日志找到。 操作步骤 在“实时同步管理”页面,单击“创建同步任务”。
和PARALLEL DML。 增量同步时,不建议选择混合分区表,因为混合分区表中的外部分区数据变更不产生DML日志,DRS增量数据同步无法获取变更信息,会存在数据不一致的风险。 增量同步时,增量解析时间类型仅支持在Oracle时间类型合法范围内的数据,超范围的数据可能导致任务异常