# 创建MQS到数据库的集成任务 #### 概述 通过数据集成任务，把MQS中的设备数据进行数据结构转换并写入停车场管理系统的数据库中。此处假设停车场管理系统的数据库为MySQL。 #### 操作步骤 1. 接入MQS数据源。 1. 在左侧的导航栏选择"数据源管理"，单击页面右上角的"接入数据源"。 2. 在接入数据源页面的"默认数据源"页签下，选择"MQS"数据源类型，然后单击"下一步"。 3. 在页面中填写MQS数据源的相关配置信息。 表1MQS数据源配置 | 参数 | 配置说明 | |:---|:---| | 数据源名称 | 填写MQS数据源的名称，自定义。 | | 集成应用 | 选择[在ROMA Connect注册设备](https://support.huaweicloud.com/bestpractice-roma/roma_05_0002.html)中所创建的集成应用。 | | 描述 | 填写数据源的描述信息。 | | 连接地址 | 选择当前ROMA Connect实例的"消息集成 MQS内网连接地址"，您可以在ROMA Connect控制台的实例信息页面查看该地址。 | | 是否SSL | 仅当ROMA Connect实例的"MQS SASL_SSL"已开启且"VPC内网明文访问"未开启时，选择"是"，其他情况下选择"否"。 | | SSL用户名/应用Key | **仅当"是否SSL"选择"是"时需要配置。** 填写[配置设备数据转发MQS](https://support.huaweicloud.com/bestpractice-roma/roma_05_0003.html)中创建的Topic所属集成应用的Key。 | | SSL密码/应用Secret | **仅当"是否SSL"选择"是"时需要配置。** 填写[配置设备数据转发MQS](https://support.huaweicloud.com/bestpractice-roma/roma_05_0003.html)中创建的Topic所属集成应用的Secret。 | 4. 完成MQS数据源参数配置后，单击"开始检测"，进行数据源的连接测试 - 若测试结果为"数据源连接成功！"，则继续下一步。 - 若测试结果为"数据源连接失败！"，则检查和修改数据源连接参数配置，然后单击"重新检测"，直到连接成功为止。 5. 单击"创建"，完成MQS数据源的接入。 2. 接入MySQL数据源。 1. 在"数据源管理"页面单击右上角的"接入数据源"。 2. 在接入数据源页面的"默认数据源"页签下，选择"MySQL"数据源类型，然后单击"下一步"。 3. 在页面中填写MySQL数据源的相关配置信息。 表2数据源配置参数 | 参数 | 配置说明 | |:---|:---| | 数据源名称 | 填写数据源的名称，自定义。 | | 集成应用 | 选择[在ROMA Connect注册设备](https://support.huaweicloud.com/bestpractice-roma/roma_05_0002.html)中所创建的集成应用。 | | 描述 | 填写数据源的描述信息。 | | 连接模式 | 选择"默认"方式。 | | 连接地址 | 填写MySQL数据库的访问IP地址。 | | 端口 | 填写MySQL数据库的访问端口，MySQL的默认访问端口为3306，以数据库的实际配置为准。 | | 数据库名 | 填写数据表所在的数据库名称。 | | 编码格式 | 数据库所使用的编码格式。 | | 超时时间（秒） | 连接数据库的超时时间，单位为秒。 | | 用户名 | 访问数据库的用户名，且该用户具备数据库的读写权限。 | | 密码 | 访问数据库的用户密码。 | 4. 完成数据源参数配置后，单击"开始检测"，进行数据源的连接测试 - 若测试结果为"数据源连接成功！"，则继续下一步。 - 若测试结果为"数据源连接失败！"，则检查和修改数据源连接参数配置，然后单击"重新检测"，直到连接成功为止。 5. 单击"创建"，完成MySQL数据源的接入。 3. 创建MQS到MySQL的数据集成任务。 1. 在左侧的导航栏选择"数据集成 FDI \> 任务管理"，单击"创建普通任务"。 2. 在创建任务页面中填写数据集成任务的相关配置信息。 1. 配置任务基本信息。 表3任务基本信息 | 参数 | 配置说明 | |:---|:---| | 任务名称 | 填写任务的名称，自定义。 | | 描述 | 填写任务的描述信息。 | | 集成模式 | 选择数据集成的模式。使用MQS作为源端数据源时仅支持实时任务，此处选择"实时"。 | | 任务标签 | 添加任务标签，用来对任务进行分类，方便用户快速查询。为简单起见，此处不设置。 | | 企业项目 | 选择任务所属的企业项目，保持默认设置"default"。 | 2. 配置源端MQS数据源信息。 表4源端配置信息 | 参数 | 配置说明 | |:---|:---| | 源端实例 | 选择当前正在使用的ROMA Connect实例。 | | 源端集成应用 | 选择[在ROMA Connect注册设备](https://support.huaweicloud.com/bestpractice-roma/roma_05_0002.html)中所创建的集成应用。 | | 源端数据类型 | 选择"MQS"。 | | 数据源名称 | 选择[1]中所配置的MQS数据源。 | | Topic名称 | 选择[配置设备数据转发MQS](https://support.huaweicloud.com/bestpractice-roma/roma_05_0003.html)中所创建的Topic。 | | 是否解析 | 源端MQS与目标端MySQL的数据结构不一样，需要对数据进行解析和转换，此处选择"是"。 | | 数据根字段 | 指从源端获取到的JSON格式数据中，元数据集上层公共字段的路径。此处不设置。 | | 数据类型 | 选择从MQS数据源获取的数据格式类型，需要与MQS实际存储的数据格式一致。存储到MQS的设备数据为JSON格式，此处选择"JSON"。 | | 消费偏移设置 | 选择"最新"，即集成最新获取的消息数据。 | | 元数据 | 指从源端获取到的JSON格式数据中，要集成到目标端的数据元素。 以车位感应设备的数据为例，需要把车位感应设备信息和车位状态信息集成到目标端数据库中。 - 别名：deviceId，类型：String，解析路径：data.deviceId - 别名：status，类型：String，解析路径：data.status | | 时区 | 选择MQS数据源使用的时区，以便ROMA Connect识别数据的时间戳。 | 3. 配置目标端MySQL数据源信息。 表5目标端配置信息 | 参数 | 配置说明 | |:---|:---| | 目标端实例 | 选择当前正在使用的ROMA Connect实例。 | | 目标端集成应用 | 选择[在ROMA Connect注册设备](https://support.huaweicloud.com/bestpractice-roma/roma_05_0002.html)中所创建的集成应用。 | | 目标端数据类型 | 选择"MySQL"。 | | 数据源名称 | 选择[2]中所配置的MySQL数据源。 | | 目标端表 | 选择MySQL数据库中集成数据要写入的数据表。 选择数据表后，单击"选择表字段"，选择车位感应设备信息和车位状态信息要写入数据库的列字段。 | | 批次号字段 | 此处不设置。 | 4. 配置MQS到MySQL的数据映射规则。 单击"自动Mapping"，自动建立源端和目标端数据字段间的映射规则。如果两端的数据表字段不一致，您需要为目标端字段选择对应的源端字段。 3. 单击"保存"，完成数据集成任务的创建。 4. 在"任务管理"页面，在刚创建的数据集成任务右侧单击"启动"，启动任务。