创建MQS到数据库的集成任务

概述

通过数据集成任务，把MQS中的设备数据进行数据结构转换并写入停车场管理系统的数据库中。此处假设停车场管理系统的数据库为MySQL。

操作步骤

1. 接入MQS数据源。
   1. 在左侧的导航栏选择“数据源管理”，单击页面右上角的“接入数据源”。
   2. 在接入数据源页面的“默认数据源”页签下，选择“MQS”数据源类型，然后单击“下一步”。
   3. 在页面中填写MQS数据源的相关配置信息。

      表1 MQS数据源配置

      参数	配置说明
      数据源名称	填写MQS数据源的名称，自定义。
      集成应用	选择在ROMA Connect注册设备中所创建的集成应用。
      描述	填写数据源的描述信息。
      连接地址	选择当前ROMA Connect实例的“消息集成 MQS内网连接地址”，您可以在ROMA Connect控制台的实例信息页面查看该地址。
      是否SSL	仅当ROMA Connect实例的“MQS SASL_SSL”已开启且“VPC内网明文访问”未开启时，选择“是”，其他情况下选择“否”。
      SSL用户名/应用Key	仅当“是否SSL”选择“是”时需要配置。 填写配置设备数据转发MQS中创建的Topic所属集成应用的Key。
      SSL密码/应用Secret	仅当“是否SSL”选择“是”时需要配置。 填写配置设备数据转发MQS中创建的Topic所属集成应用的Secret。

   4. 完成MQS数据源参数配置后，单击“开始检测”，进行数据源的连接测试
      • 若测试结果为“数据源连接成功！”，则继续下一步。
      • 若测试结果为“数据源连接失败！”，则检查和修改数据源连接参数配置，然后单击“重新检测”，直到连接成功为止。
   5. 单击“创建”，完成MQS数据源的接入。
2. 接入MySQL数据源。
   1. 在“数据源管理”页面单击右上角的“接入数据源”。
   2. 在接入数据源页面的“默认数据源”页签下，选择“MySQL”数据源类型，然后单击“下一步”。
   3. 在页面中填写MySQL数据源的相关配置信息。

      表2 数据源配置参数

      参数	配置说明
      数据源名称	填写数据源的名称，自定义。
      集成应用	选择在ROMA Connect注册设备中所创建的集成应用。
      描述	填写数据源的描述信息。
      连接模式	选择“默认”方式。
      连接地址	填写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注册设备中所创建的集成应用。
         源端数据类型	选择“MQS”。
         数据源名称	选择1中所配置的MQS数据源。
         Topic名称	选择配置设备数据转发MQS中所创建的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注册设备中所创建的集成应用。
         目标端数据类型	选择“MySQL”。
         数据源名称	选择2中所配置的MySQL数据源。
         目标端表	选择MySQL数据库中集成数据要写入的数据表。 选择数据表后，单击“选择表字段”，选择车位感应设备信息和车位状态信息要写入数据库的列字段。
         批次号字段	此处不设置。

      4. 配置MQS到MySQL的数据映射规则。

         单击“自动Mapping”，自动建立源端和目标端数据字段间的映射规则。如果两端的数据表字段不一致，您需要为目标端字段选择对应的源端字段。

   3. 单击“保存”，完成数据集成任务的创建。
   4. 在“任务管理”页面，在刚创建的数据集成任务右侧单击“启动”，启动任务。