# 创建DRS同步任务
本章节介绍创建DRS实例，将RDS for MySQL上的数据库增量同步到Kafka。
#### 同步前检查
在创建任务前，需要针对同步条件进行手工自检，以确保您的同步任务更加顺畅。
本示例中，为RDS for MySQL到Kafka的出云同步，您可以参考[出云同步使用须知](https://support.huaweicloud.com/realtimesyn-drs/drs_04_0118.html)获取相关信息。
#### 操作步骤
1. 登录[华为云控制台](https://console.huaweicloud.com)。
2. 单击管理控制台左上角的![](https://support.huaweicloud.com/bestpractice-drs/zh-cn_image_0000001243645639.png)，选择区域"华南-广州"。
3. 单击左侧的服务列表图标，选择"数据库 \> 数据复制服务 DRS"。
4. 选择左侧"实时同步管理"，单击"创建同步任务"。
5. 填写同步任务参数： 
   1. 配置同步任务名称。 ![](https://support.huaweicloud.com/bestpractice-drs/zh-cn_image_0000001606820550.png)
      
      
   
   2. 选择需要同步任务的源库、目标数据库以及网络信息。 这里的源库选择[源端RDS for MySQL准备](https://support.huaweicloud.com/bestpractice-drs/drs_06_0008.html)创建的RDS实例。
      图1同步实例信息   
      ![](https://support.huaweicloud.com/bestpractice-drs/zh-cn_image_0000002142324025.png)
      
      
   
   3. 企业项目选择"default"。 ![](https://support.huaweicloud.com/bestpractice-drs/zh-cn_image_0000001606660770.png)
      
   
   
   
   
6. 单击"开始创建"。 
   同步实例创建中，大约需要5-10分钟。
   
   
7. 配置源库信息和目标库数据库密码。 
   1. 配置源库信息。
   
   2. 单击"测试连接"。 当界面显示"测试成功"时表示连接成功。
      ![](https://support.huaweicloud.com/bestpractice-drs/zh-cn_image_0000001606980258.png)
      
   
   3. 选择目标库所在VPC和子网，填写Kafka的IP地址和端口。
   
   4. 单击"测试连接"。 当界面显示"测试成功"时表示连接成功。
      ![](https://support.huaweicloud.com/bestpractice-drs/zh-cn_image_0000001607020234.png)
      
      
   
   
   
   
8. 单击"下一步"。
9. 选择同步信息、策略、消息格式和对象等，投递到Kafka的消息格式。 
   本次选择如下。
   表1同步设置 
   | **类别**               | **设置**                                                                                      |
   |:---|:---|
   | 同步Topic策略            | 集中投递到一个Topic，Topic名称"testTopic"。                                                            |
   | 同步到Kafka partition策略 | 按表名+库名的hash值投递到不同Partition。                                                                 |
   | 投递到Kafka的数据格式        | 可选择JSON格式，可参考[Kafka消息格式](https://support.huaweicloud.com/realtimesyn-drs/drs_03_0052.html)。 |
   | 同步对象                 | 同步对象选择db_test下的table3_表。                                                                    |
      
   ![](https://support.huaweicloud.com/bestpractice-drs/zh-cn_image_0000001655980457.png)
   
   
   
10. 单击"下一步"。
11. 选择数据加工方式。RDS for MySQL到Kafka数据同步目前只支持列加工，列加工提供列级的查询和过滤能力。 
    ![](https://support.huaweicloud.com/bestpractice-drs/zh-cn_image_0000001606820558.png)
    
    
12. 单击"下一步"，等待预检查结果。
13. 当所有检查都是"通过"时，单击"下一步"。 
    ![](https://support.huaweicloud.com/bestpractice-drs/zh-cn_image_0000001655820205.png)
    
    
14. 确认同步任务信息正确后，单击"启动任务"。 
    返回DRS实时同步管理，查看同步任务状态。
    启动中状态一般需要几分钟，请耐心等待。
    ![](https://support.huaweicloud.com/bestpractice-drs/zh-cn_image_0000001655860525.png)
    当状态变更为"增量同步"，表示同步任务已启动。
    ![](https://support.huaweicloud.com/bestpractice-drs/public_sys-resources/note_3.0-zh-cn.png)
    - 当前示例中RDS for MySQL到Kafka选择单增量同步，任务启动后为增量同步状态。
    
    - 如果创建的任务为全量+增量同步，任务启动后先进入全量同步，全量数据同步完成后进入增量同步状态。
    
    - 增量同步会持续性同步增量数据，不会自动结束。