本文介绍通过应用集成实现从数据库源表到目标表的数据集成转换。完成从数据库源表定期读取数据,然后写入目标表,过程中如果两者数据结构存在差异可以加入数据映射逻辑步骤。
前提条件
- 在阿里云容器服务Kubernetes版上创建了Database服务。具体操作步骤,请参见使用镜像快速创建无状态Deployment应用。
- 已经在Database创建contact表和todo表,并在contact表写入数据。本场景从contact表读取数据,然后存入todo表。
- 本地已经安装MySQL客户端。
背景信息
通过集成流配置可以实现从源数据库表中读取数据,并将数据写入到目标数据库表中。
本文创建的集成将实现以下功能:
- 从数据库的contact表中定期读取数据。
- 将读取到的数据写入到数据库的todo表中。
创建连接
本示例中会用到Database,所以需要借助连接器创建对应的连接。
创建Database连接,请参见创建连接。
创建空白集成
- 登录应用集成控制台。
- 在顶部菜单栏,选择地域。
- 在左侧导航栏,选择 。
- 在集成列表页面,选择目标工作空间,然后单击新建集成。
- 在新建集成面板,选择创建方式为空白流,选择目标环境,输入集成名称,然后单击创建。
- 集成创建后,进入集成设计页面,选择接下来的操作。
- 在右上角单击保存,创建一个空集成。
- 在页面左上角单击图标,在列表中单击Flow,创建集成流。
创建集成流
部署集成
集成创建并保存后,需要对集成进行部署。具体操作,请参见部署集成示例。
结果验证
- todo表数据对比。
- 使用MySQL客户端连接Datebase服务器,在MySQL客户端输入select * from todo查询todo表是否含有从contact表读取的数据。
- 您也可以在contact表新增一组数据,然后在todo表查看task字段的值是否是新增的first_name字段的值。
- 验证集成部署是否正常运行。
查看目标集成的执行记录,其执行日志的状态是否为SUCCESS。