检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Notification，SMN）是可靠的、可扩展的、海量的消息处理服务。它可以依据用户的需求主动推送通知消息，最终用户可以通过短信、电子邮件、应用等方式接收。 对DRS而言 SMN为其他服务均可使用的通用服务，仅需在SMN界面统一配置，如果在其他服务使用时已完成创建和订阅，DRS可以直接选择相应的订阅主题。
由于本次实践为增量同步模式，DRS任务会将源库的产生的增量数据持续同步至目标库中，直到手动任务结束。下面我们通过在源库RDS for MySQL中插入数据，查看Kafka的接收到的数据来验证同步结果。 操作步骤 登录华为云控制台。 单击管理控制台左上角的，选择区域“华南-广州”。 单击左侧的服务列表图标，选择“数据库
使用主1、主2来区分角色。主1表示选择的本云RDS具有初始数据，主2则表示选择本云RDS为空库，等待接收数据。 如图1， 选择主2，表示创建任务时选择的本云数据库实例为空库，待接收数据，创建成功后，需先配置表示入云的正向任务，待正向任务进入“灾备中”状态时，再配置并启动反向任务。
MySQL或MariaDB不同版本之间的语法差异 对于源数据库和目标数据库的版本有差异的迁移和同步链路，由于不同版本之间的部分特性差异，可能会出现语法兼容性问题。 DRS接收到的源数据库Binlog日志中里保存的是原始的执行SQL语句，这些SQL语句将会直接在目标数据库中执行，如果目标数据库对于源数据库中执行S
状态码如表1所示： 表1 状态码 状态码 编码 错误码说明 100 Continue 继续请求。 这个临时响应用来通知客户端，它的部分请求已经被服务器接收，且仍未被拒绝。 101 Switching Protocols 切换协议。只能切换到更高级的协议。 例如，切换到HTTP的新版本协议。 200
主1：一般具有业务数据，创建任务时选择主1则表示本云RDS具有初始数据。 主2：必须为空数据库，创建任务时选择主2则表示本云RDS为空库，等待接收数据。 创建灾备任务时，选择主1、主2应遵循以下原则 灾备双方均为本云RDS实例。 有一方为空实例，空实例作为主2，非空实例作为主1。 双
则可能导致任务失败。 请勿修改源库中表的REPLICA IDENTITY值，否则可能导致增量数据不一致或任务失败。 请勿在Kafka上删除接收DRS数据的topic，否则可能导致任务失败。 选择表级对象迁移时，同步过程中不建议对表进行重命名操作。 不支持interval partition表复制。
错误码 调用接口出错后，将不会返回结果数据。调用方可根据每个接口对应的错误码来定位错误原因。 当调用出错时，HTTP请求返回一个HTTP状态码。返回的消息体中是具体的错误编码及错误描述信息。 当您调用API时，如果遇到“APIGW”开头的错误码，请参见API网关错误码进行处理。 表1
由于本次实践为增量同步模式，DRS任务会将源库的产生的增量数据持续同步至目标库中，直到手动任务结束。下面我们通过在源库GaussDB中插入数据，查看Kafka的接收到的数据来验证同步结果。 登录华为云控制台。 单击管理控制台左上角的，选择区域。 单击左侧的服务列表图标，选择“数据库 > 云数据库 GaussDB””。
缺失或任务失败。 请勿修改源数据库中表的replica identity属性，否则可能导致增量数据缺失或任务失败。 请勿在Kafka上删除接收DRS数据的topic，否则可能导致任务失败。 库级同步时，源库新增无主键表时，请务必同时将该无主键表的replica identity属
由于本次实践为增量同步模式，DRS任务会将源库的产生的增量数据持续同步至目标库中，直到手动任务结束。下面我们通过在源库GaussDB中插入数据，查看Kafka的接收到的数据来验证同步结果。 登录华为云控制台。 单击管理控制台左上角的，选择区域。 单击左侧的服务列表图标，选择“数据库 > 云数据库 GaussDB””。
消息通知服务（Simple Message Notification）可以依据华为云用户的需求主动推送通知消息，最终用户可以通过HTTP、HTTPS、应用等方式接收通知信息。华为云用户也可以在应用之间通过消息通知服务实现应用的功能集成，降低系统的复杂性。 消息通知服务的更多信息，请参见《消息通知服务用户指南》。
ClusterListener接口定义 函数名称 说明 void notify(List<ClusterMessage> var1) 该函数主要用于定义增量数据的消费。当SDK接收到数据时，会通过notify通知ClusterListner消费数据。例如SDK使用模板的消费方式，就是将订阅数据打印到屏幕上。 该函数输入参数类型为：List
批量配置异常通知 功能介绍 批量设置告警信息，已结束的任务不支持设置。 支持选择已有的SMN主题和手动输入手机号、邮箱两种方式，具体根据自己使用情况选择。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。
请勿在目标库做写入操作，否则可能导致数据不一致。 为保证同步任务正常和数据的一致性，如有以上诉求，建议在业务低峰期时重新创建DRS任务。 请勿在Kafka上删除接收DRS数据的topic，否则可能导致任务失败。 不支持DDL操作，源数据库进行的DDL操作不会同步到目标数据库。 不支持大数据类型IMAGE、TEXT、NTEXT的删除操作。
请勿在目标库做写入操作，否则可能导致数据不一致。 为保证同步任务正常和数据的一致性，如有以上诉求，建议在业务低峰期时重新创建DRS任务。 请勿在Kafka上删除接收DRS数据的topic，否则可能导致任务失败。 不支持DDL操作，源数据库进行的DDL操作不会同步到目标数据库。 不支持大数据类型IMAGE、TEXT、NTEXT的删除操作。
增量同步过程中暂停、任务异常续传，目标Kafka中可能会出现重复数据，请使用Kafka数据中的id字段进行去重。 增量同步过程中，请勿在Kafka上删除接收DRS数据的topic，否则可能导致任务失败。 操作步骤 本小节以DDS到Kafka的出云单增量实时同步为示例，介绍如何使用数据复制服务配置实时同步任务。
的操作；也不允许将单表/广播表改为拆分表，拆分表改为单表/广播表。 增量同步阶段，支持DDL操作。 增量同步过程中，请勿在Kafka上删除接收DRS数据的topic，否则可能导致任务失败。 操作步骤 在“实时同步管理”页面，单击“创建同步任务”。 在“同步实例”页面，填选区域、项
批量测试连接-集群模式 功能介绍 批量测试连接（集群模式）。 主备任务测试连接 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 接口约束 任务创建成功之后，任务状态为CONFIGURATION才能进行测试连接。
批量修改任务 功能介绍 批量修改任务名称或描述，设置异常通知信息。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 接口约束 源库和目标库均测试连接成功之后需要调用该接口，请
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
