# 使用ROMA Connect的FDI实现API到MQS的数据转换
#### 概述
ROMA Connect支持接入多种类型的数据源，并通过数据集成任务实现源端到目标端的数据集成转换。ROMA Connect支持相同结构数据之间进行集成转换，也支持异构数据之间进行集成转换。
本章节通过完成一个API到MQS的数据集成配置样例，帮助您快速熟悉使用ROMA Connect FDI集成数据的过程。
使用ROMA Connect集成数据的步骤如下所示：
- [步骤一：准备数据源]
- [步骤二：接入数据源]
- [步骤三：创建数据集成任务]
- [步骤四：启动数据集成任务]
- [步骤五：查看数据集成结果]
 
 #### 步骤一：准备数据源
在使用ROMA Connect进行数据集成前，您需要准备一个API数据源和MQS数据源，作为本配置样例中的源端和目标端数据源。
1. 创建并发布一个函数API。 在当前ROMA Connect实例上创建、调试并发布一个API，作为源端API数据源，具体请参考[创建API](https://support.huaweicloud.com/qs-roma/roma_02_0002.html#roma_02_0002__section183961356183620)、[调试API](https://support.huaweicloud.com/qs-roma/roma_02_0002.html#roma_02_0002__section15179201019102)和[发布API](https://support.huaweicloud.com/qs-roma/roma_02_0002.html#roma_02_0002__section44531307115)。
   为简单起见，该函数API无需请求认证、不带请求参数，并调用该函数API时固定返回消息"ROMA TEST!"。
   函数API创建完成后，记录该API的请求URL和请求方法。
   
2. 创建一个消息Topic。 在当前ROMA Connect实例上创建一个消息集成Topic，作为目标端MQS数据源的Topic，具体请参考[创建消息Topic](https://support.huaweicloud.com/qs-roma/roma_02_0003.html#roma_02_0003__section36017538917)。
   Topic创建完成后，记录该Topic的名称，并在ROMA Connect实例控制台的"集成应用"页面中，单击Topic所属集成应用的名称，查看并获取Key和Secret。
   
 
 #### 步骤二：接入数据源
在创建数据集成任务前，您需要先配置ROMA Connect接入API和MQS数据源，确保可以正常从源端读取数据及向目标端写入数据。
1. 创建集成应用。
   1. 登录[ROMA Connect控制台](https://console.huaweicloud.com/roma3)，在左侧导航栏选择"资源管理"，在实例页面单击实例，进入实例控制台。
   
   2. 在左侧的导航栏选择"集成应用"，单击页面右上角的"创建集成应用"。
   
   3. 在创建集成应用弹窗中填写集成应用的"名称"，然后单击"确认"。
    
2. 接入API数据源。
   1. 在左侧的导航栏选择"数据源管理"，单击页面右上角的"接入数据源"。
   
   2. 在接入数据源页面的"默认数据源"页签下，选择"API"数据源类型，然后单击"下一步"。
   
   3. 在页面中填写API数据源的相关配置信息。
      表1API数据源配置 
      | 参数    | 配置说明                                                            |
      |:---|:---|
      | 数据源名称 | 填写API数据源的名称，根据规划自定义。建议您按照一定的命名规则填写数据源名称，方便您快速识别和查找。             |
      | 集成应用  | 选择[1]中所创建的集成应用。                 |
      | 描述    | 填写API数据源的描述信息。                                                  |
      | 地址    | 填写[步骤一：准备数据源]中记录的API请求URL。 |
      | 请求方式  | 选择[步骤一：准备数据源]中记录的API请求方法。  |
      | 认证方式  | API数据源无需请求认证，此处选择"None"。                                        |
         
      
   
   4. 完成API数据源参数配置后，单击"开始检测"，进行数据源的连接测试
      - 若测试结果为"数据源连接成功！"，则继续下一步。
      
      - 若测试结果为"数据源连接失败！"，则检查和修改数据源连接参数配置，然后单击"重新检测"，直到连接成功为止。
       
   
   5. 单击"创建"，完成API数据源的接入。
    
3. 接入MQS数据源。
   1. 在"数据源管理"页面单击右上角的"接入数据源"。
   
   2. 在接入数据源页面的"默认数据源"页签下，选择"MQS"数据源类型，然后单击"下一步"。
   
   3. 在页面中填写MQS数据源的相关配置信息。
      表2MQS数据源配置 
      | 参数             | 配置说明                                                                                                                             |
      |:---|:---|
      | 数据源名称          | 填写MQS数据源的名称，根据规划自定义。建议您按照一定的命名规则填写数据源名称，方便您快速识别和查找。                                                                              |
      | 集成应用           | 选择[1]中所创建的集成应用。                                                                                  |
      | 描述             | 填写MQS数据源的描述信息。                                                                                                                   |
      | 连接地址           | 选择当前ROMA Connect实例的"消息集成 MQS内网连接地址"，您可以在ROMA Connect控制台的实例信息页面查看该地址。                                                             |
      | 是否SSL          | 仅当ROMA Connect实例的"MQS SASL_SSL"已开启且"VPC内网明文访问"未开启时，选择"是"，其他情况下选择"否"。                                                             |
      | SSL用户名/应用Key   | **仅当"是否SSL"选择"是"时需要配置。** 填写[步骤一：准备数据源]中记录的Topic所属集成应用的Key。  |
      | SSL密码/应用Secret | **仅当"是否SSL"选择"是"时需要配置。** 填写[步骤一：准备数据源]中记录的Topic所属集成应用的Secret。 |
         
      
   
   4. 完成MQS数据源参数配置后，单击"开始检测"，进行数据源的连接测试
      - 若测试结果为"数据源连接成功！"，则继续下一步。
      
      - 若测试结果为"数据源连接失败！"，则检查和修改数据源连接参数配置，然后单击"重新检测"，直到连接成功为止。
       
   
   5. 单击"创建"，完成MQS数据源的接入。
    
 
 #### 步骤三：创建数据集成任务
在完成了API和MQS数据源的接入配置后，您即可以开始创建源端到目标端的数据集成任务。
1. 在左侧的导航栏选择"数据集成 FDI \> 任务管理"，单击"创建普通任务"。
2. 在创建任务页面中填写数据集成任务的相关配置信息。
   1. 配置任务基本信息。
      表3任务基本信息 
      | 参数        | 配置说明                                                |
      |:---|:---|
      | 任务名称      | 填写任务的名称，根据规划自定义。建议您按照一定的命名规则填写任务名称，方便您快速识别和查找。      |
      | 任务时区补偿偏移量 | 时区偏移量补偿机制，源端时区以UTC+0为标准，目标端时区是客户自己需要，来计算目标端和源端的偏移量。 |
      | 集成模式      | 选择数据集成的模式。使用API作为源端数据源时仅支持定时任务，此处选择"定时"。            |
      | 描述        | 填写任务的描述信息。                                          |
      | 任务标签      | 添加任务标签，用来对任务进行分类，方便用户快速查询。为简单起见，此处不设置。              |
      | 企业项目      | 选择任务所属的企业项目，保持默认设置"default"。                        |
         
      
   
   2. 配置任务计划信息。 为简单起见，任务计划信息保持默认设置。
      
   
   3. 配置源端API数据源信息。
      图1源端配置信息   
      ![](https://support.huaweicloud.com/qs-roma/zh-cn_image_0000001084222824.png "点击放大")
      表4源端配置信息 
      | 参数     | 配置说明                                                         |
      |:---|:---|
      | 源端实例   | 选择当前正在使用的ROMA Connect实例。                                     |
      | 源端集成应用 | 选择[步骤二：接入数据源]中所创建的集成应用。   |
      | 源数据类型  | 选择"API"。                                                     |
      | 数据源名称  | 选择[步骤二：接入数据源]中所配置的API数据源。 |
      | 是否需要分页 | 为简单起见，此处不开启。                                                 |
      | 是否增量迁移 | 为简单起见，此处不开启。                                                 |
      | 请求参数   | API数据源无请求参数，此处不设置。                                           |
      | 是否解析   | 为简单起见，此处选择"否"。                                               |
         
      
   
   4. 配置目标端MQS数据源信息。
      图2目标端配置信息   
      ![](https://support.huaweicloud.com/qs-roma/zh-cn_image_0000001083774758.png "点击放大")
      表5目标端配置信息 
      | 参数      | 配置说明                                                         |
      |:---|:---|
      | 目标端实例   | 选择当前正在使用的ROMA Connect实例。                                     |
      | 目标端集成应用 | 选择[步骤二：接入数据源]中所创建的集成应用。   |
      | 目标数据类型  | 选择"MQS"。                                                     |
      | 数据源名称   | 选择[步骤二：接入数据源]中所配置的MQS数据源。 |
      | Topic名称 | 选择[步骤一：准备数据源]中记录的Topic。 |
      | Key     | 为简单起见，此处不设置。                                                 |
         
      
   
   5. 任务执行后完成配置保持默认。
    
3. 单击"保存"，完成数据集成任务的创建。然后单击"返回任务列表"，在任务列表中可以查看刚创建的数据集成任务。
 
 #### 步骤四：启动数据集成任务
数据集成任务创建后，"任务状态"为"停止"状态，此时任务不会执行，需先启动任务。
数据集成任务有两种启动方式：
- **启动任务计划** ，任务按照创建任务时所设置的计划执行。
  在数据集成任务左侧勾选上要启动的任务，单击任务列表上方的"启动"，启动任务计划，然后等待任务按计划时间执行。
  
- **手动执行任务** ，仅执行一次。手动执行任务前，需确保"任务状态"为"停止"状态。
  单击数据集成任务右侧的"手工调度"，手动执行任务，待任务的"运行状态"为"执行成功"时，任务执行完成。
  
为了可以马上执行数据集成任务并查看任务结果，此处使用手动执行任务的方式，执行API到MQS的数据集成任务。
 #### 步骤五：查看数据集成结果
1. 在左侧的导航栏选择"消息集成MQS \> 消息查询"，进入消息查询页面。
2. 单击"高级搜索"展开高级搜索框。
3. 输入搜索条件，然后单击"搜索"，查询客户端发送的消息记录。
   - "Topic名称"选择[步骤一：准备数据源]中创建的消息Topic。
   
   - "查询方式"选择"按生产时间查询"，并选择客户端向ROMA Connect发送消息的时间段。
    
4. 单击消息记录后的"消息内容"，查看消息内容，确认是否与API的响应消息一致。
   图3查看消息   
   ![](https://support.huaweicloud.com/qs-roma/zh-cn_image_0000001131005149.png "点击放大")