本文介绍通过HTTP请求将数据库源表内容写入目标表。完成获取数据库源表内容，将获取内容作为HTTP请求Body，然后发送POST请求将获取的内容写入目标表。

前提条件

  • 在阿里云容器服务Kubernetes版上创建了Database服务。操作步骤，请参见使用镜像快速创建无状态Deployment应用。
  • 本场景在Database里已经创建contact表和task表，且已经在contact表中录入数据，contact表数据包含id、first_name、last_name、company、leader_source、create_date和completed字段，而task表数据只有id、task和completed字段。

背景信息

通过集成流配置可以实现从数据库源表中获取内容，将获取内容作为HTTP请求的Body，然后发送POST请求将获取的数据写入到目标表中。

本文创建的集成将实现以下功能：
  1. 从数据库的contact表中定期获取数据。
  2. 将获取到的数据写入到数据库的task表中。

创建连接

本示例中会用到Database和REST-Swagger，所以需要借助连接器创建对应的连接。

创建空白集成

  1. 登录应用集成控制台。
  2. 在顶部菜单栏，选择地域。
  3. 在左侧导航栏，选择集成 > 集成列表。
  4. 在集成列表页面，选择目标工作空间，然后单击新建集成。
  5. 在新建集成面板，选择创建方式为空白流，选择目标环境，输入集成名称，然后单击创建。
  6. 集成创建后，进入集成设计页面，在右上角单击保存。

创建集成流

  1. 在集成设计页面左上角，单击图标，在列表中单击Flow，创建集成流。
    也可以在页面中，选择点击创建 > Flow，创建集成流。
  2. 选择触发器，实现从Database的contact表中定期读取数据。
    1. 在创建新集成流对话框，输入名称，选择Database作为触发器，然后单击创建。选择触发器-Database
    2. 在选择操作对话框，单击Periodic SQL invocation右侧的选择。选择operation
    3. 在步骤配置对话框，设置SQL语句和周期，然后单击确定。步骤配置-设置SQL语句
      本场景中SQL语句设置为select * from contact，周期设置为6000，单位ms。
    4. 在设置outputDataShape对话框，在选择schema列表中选择任意类型，然后单击创建。
    创建完成后，集成流即包含了从Database的contact表定期读取数据的触发器。从contact定期读取数据
  3. 在集成流中添加REST-Swagger连接，将获取的数据写入Database的task表中。
    1. 在集成流中Periodic SQL invocation后单击图标。
    2. 在选择组件类型对话框，单击连接，然后单击REST-Swagger连接。
    3. 在选择操作对话框，单击Create new task右侧的选择。新建task表
    4. 在步骤配置对话框，单击确定。
      步骤配置完成后，Create new task出现在集成流中。读取数据-插入指定表
  4. 在集成流中添加数据映射器，完成字段映射。
    1. 鼠标悬停在集成流中Periodic SQL invocation右侧的上，然后单击图标。
    2. 在选择组件类型对话框，单击逻辑步骤，然后单击data-mapper（数据映射器）。
    3. 在Source > 1-SQL Result > Document Root与Target > 2-SQL Request之间单击字段进行映射，然后单击确认。
      字段映射
      字段映射关系如下：
      Source目录 Source字段 Target字段（2-SQL Result）
      Source > 1-SQL Result > Document Root id id
      completed completed
      company 您可以据实际需要选择字段与task字段映射，本场景以字段company和task为例进行映射。
      create_date
      first_name
      last_name
      leader_source
    4. 在设置对话框，在选择schema列表中选择任意类型，然后单击创建。
    创建完成后，集成流中即出现字段映射的逻辑步骤。读取数据-字段映射-新建表和写入数据
  5. 在集成流中添加拆分器，实现单独处理每一项数据。
    1. 鼠标悬停在集成流中Periodic SQL invocation右侧的上，然后单击图标。
    2. 在选择组件类型对话框，单击逻辑步骤，然后单击split（拆分器）。
    3. 单击确定，完成逻辑步骤的创建。
  6. 在集成设计页面右上角，单击保存，保存集成流。
    Swagger API处理的集成流创建完成。Swagger API处理
    注意 返回集成设计页面时，请及时在页面右上角单击保存，以免添加的步骤丢失。

部署集成

集成创建并保存后，需要对集成进行部署。具体操作，请参见部署集成示例。

结果验证

  • task表数据对比。
    • 使用MySQL客户端连接Datebase服务器，在MySQL客户端输入select * from task查询task表数据，查看task表字段和contact字段是否对应。
    • 您也可以在contact表新增一组数据，然后查看task表字段和contact字段是否对应。
    本场景的字段对应关系如下：
    task表字段 contact表字段
    id id
    task company
    completed completed
  • 验证集成部署是否正常运行。

    查看目标集成的执行记录，其执行日志的状态是否为SUCCESS。