本文介绍通过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后单击图标。