实时集成至MaxCompute

将MySQL、Oracle和PostgreSQL数据实时同步至MaxCompute,可以通过创建实时集成任务实现。本文为您介绍如何创建实时集成任务。

前提条件

已完成数据源配置。您需要在配置实时集成任务前,配置好您需要集成的数据源,以便在配置实时集成任务过程中,选择对应的来源数据和目标数据。具体操作,请参见实时集成支持的数据源

步骤一:新建实时集成任务

  1. 在Dataphin首页的顶部菜单栏中,选择研发 > 数据集成

  2. 在顶部菜单栏选择项目(Dev-Prod模式还需要选择环境)。

  3. 在左侧导航栏中,选择集成 > 实时集成

  4. 单击实时集成列表中的image图标,选择实时集成任务,打开新建实时集成任务对话框。

  5. 新建实时集成任务对话框中,配置以下参数。

    参数

    描述

    任务名称

    填写实时任务名称。

    以字母开头,仅包含小写英文字母、数字、下划线(_),长度限制为4~63个字符。

    描述

    填写任务的简单描述信息,长度不超过1000个字符。

    选择目录

    选择实时任务所存放的目录。

    若未创建目录,您可以新建文件夹,操作方法如下:

    1. 在页面左侧实时任务列表上方单击image图标,打开新建文件夹对话框。

    2. 新建文件夹对话框中输入文件夹名称并根据需要选择目录位置。

    3. 单击确定

  6. 配置完成后,单击确定

  7. 在新建的实时集成任务中,配置来源数据目标数据

    1. 数据源配置

      分区

      参数

      描述

      来源数据

      数据源类型

      选择数据源类型。支持MySQLOraclePostgreSQL

      数据源

      选择数据源。

      系统提供新建数据源入口,您可以单击新建,在数据源页面新建数据源。具体操作,请参见实时集成支持的数据源

      重要

      需在数据源端开启日志,并需确保配置的账户有读取日志权限,否则系统无法实时同步该数据源。

      同步方案

      仅支持实时增量。将源数据库的增量变更按照变更发生的顺序采集并实时写入下游目标库中。

      圈选方式

      支持整库、圈选表、排除表三种方式。

      • 整库:对当前数据库进行整库数据同步。

        仅当来源数据源类型选择MySQL时,将同步所选数据源下所有数据库中的所有表。

      • 圈选表/排除表:选中当前数据库中部分表进行实时同步。

        • 批量选择/批量排除批量选择时,所选择当前数据库的多个表将进行实时同步;批量排除时,所选择当前数据库的多个表将不进行实时同步。

          来源数据源类型选择MySQL时,支持选择所选数据源下所有数据库中的所有表,列表中以DBname.Tablename格式展示各表。

          来源数据源类型选择PostgreSQL时,不支持排除表方式。

        • 正则匹配:可在正则表达式输入框内填写表名的正则表达式。适用Java正则表达式,如schemaA.*|schemaB.*

          仅当来源数据源类型选择MySQL时,支持批量匹配所选数据源下所有数据库中的所有表,可使用数据库名(DBname)和表名(Tablename)进行正则匹配。

          来源数据源类型选择PostgreSQLMicrosoft SQL ServerIBM DB2时,不支持正则匹配

      目标数据

      数据源类型

      选择MaxCompute数据源类型。

      数据源

      选择目标数据源。支持选择MaxCompute数据源与项目。

      系统提供新建数据源入口,您可以单击新建,在数据源页面新建数据源。具体操作,请参见创建MaxCompute数据源

      新建表类型

      可选择普通表Delta表,默认为普通表。选择Delta表后,目标表配置中若目标表建立方式为自动建表,则会创建MaxCompute Delta表;建Delta表时,不使用附加字段。

      说明

      完成目标表配置后,再修改新建表类型,此时系统会发起二次确认,您若在弹出的对话框中单击确定目标表配置将被清空,后续需重新填写。

      表名转换

      单击配置表名转换,在配置表名转换规则对话框中配置转换规则。

      说明
      • 单击新建规则新增一行,最多显示5行。

      • 规则从上到下进行匹配替换。

      • 替换字符及表名前后缀中的英文字符将自动转换为小写。

      • 目标表表名前后缀不能为空且支持32个字符以内的英文字母、数字及下划线。

      分区设置

      分区间隔:默认小时(hour),可选择天(day)。

      说明
      • 分区间隔-小时:为YYYY、MM、DD、HH四级分区。

      • 分区间隔-天:为YYYY、MM、DD三级分区。

      格式:目前仅支持多分区

    2. 目标表配置

      image..png

      区块

      说明

      查看附加字段

      实时增量同步时,自动建表默认会添加附加字段以便数据使用。单击查看附加字段查看字段。在附加字段对话框中,可查看当前所附加的字段信息。

      重要

      如选择已有表作为目标表,且表中无附加字段,建议自行为已有目标表添加附加字段,否则影响数据使用。

      单击查看添加字段的DDL可查看添加附加字段的DDL语句。

      搜索与筛选

      支持按源表目标表名进行搜索。如需快速筛选目标表,单击顶部的1图标,支持按映射状态建表方式进行筛选。

      全局字段刷新表及映射关系

      • 全局字段:

        单击添加全局字段,可在添加全局字段对话框中添加全局字段。

        • 名称:全局的名称。

        • 类型:支持StringLongDoubleDateBoolean,5种数据类型。

        • :全局字段的值。

        • 描述:对字段的描述。

        说明
        • 全局和单表同时添加了字段时,仅单表添加字段生效。

        • 目前仅支持添加常量。

        • 全局字段仅对方式为自动建表的目标表生效。

      • 刷新

        如需刷新目标表配置列表,请单击刷新表及映射关系

        重要
        • 目标表配置中已有内容时,重新选择数据源类型及数据源会导致目标表列表及映射关系情况重置,请谨慎操作。

        • 刷新过程中随时可点击再次刷新。每次点击刷新表及映射关系,只保存配置的全局增加字段,其他信息包括目标表建立方式、目标表名及删除记录,都不保存。

      目标库列表

      目标库列表包括序号源表映射状态目标表建立方式目标表名、同时您可以对目标表进行添加字段查看字段刷新删除的操作。

      • 目标表建立方式分为以下三种:

        • 若目标库中存在与来源表同名的表,则目标表建立方式为使用已有表,默认使用此表作为目标表。如需改为自动建表,需添加表名转换规则或前后缀后重新进行映射。

        • 若目标库中未找到同名表,则目标表建立方式默认为自动建表,也可更换方式为使用已有表,选择已存在的表进行同步。

        • 仅自动建表的表支持添加字段或自定义DDL建表,全局字段也仅对自动建表的表生效。

      • 目标表名目标表名仅支持英文字母、数字及下划线(_)。如果来源表名中含有其他字符,需配置表名转换规则。

        当目标表建立方式为自动建表,且新建表类型选择为Delta表时,目标表名后将展示image图标,表示将新建Delta表。当目标表建立方式为使用已有表时,用户若选中目标表列表中的Delta表,目标表名后也将展示image图标,表示该表为Delta表。

      • 映射状态:不同的映射状态显示不同的操作项。分别为:

        • 完成:正常完成映射。

        • 未完成:修改状态后,未刷新映射。

        • 映射中:正在等待映射或在映射中。

        • 异常:存在数据源或系统内部错误。

        • 失败:目标分区表与实时任务设定的分区不一致。

        • 告警:来源表与目标表存可能存在不兼容的数据类型。

      • 自定义建表:可通过添加字段DDL方式自定义建表;开启自定义建表后,全局添加字段不再生效。

        说明
        • 添加字段后只在自动建表的操作栏里展示。

        • 不支持修改已存在的目标表,即建表方式为使用已有表的目标表。

        • 新建表类型选择了Delta表时,DDL建表生成Delta表的DDL(根据新建表类型获取对应的DDL);反之,则生成普通表的DDL。

      • 查看字段:可查看源表及目标表的字段和类型。

      • 刷新:重新进行源表和目标表的映射。

      • 删除:源表删除后不可撤销。

        说明

        目标表名仅支持英文字母、数字及下划线。如来源表名含有其他字符,请配置表名转换规则。

      批量操作

      您可对目标表进行批量删除操作。

    3. DDL处理策略

      • 正常处理:此DDL信息将继续下发给目标数据源,由目标数据源处理,不同目标数据源处理策略会不同。

      • 忽略:丢弃掉此DDL信息,不再向目标数据源发送此信息。

      • 出错:直接让实时同步任务以出错状态终止运行。

      说明
      • DDL处理策略仅支持来源数据MySQL、Oracle。不支持PostgreSQL。

      • 对MaxCompute表已存在的分区添加的新增列无法被同步数据,即已存在分区中新增列的数据均为NULL,下一个新建分区正常生效可用。

  8. 配置完成后,单击保存

步骤二:配置实时集成任务属性

  1. 单击当前实时集成任务页签顶部菜单栏中的资源配置,或单击右侧边栏的属性,打开属性面板。

  2. 分别配置当前实时集成任务的基本信息资源配置

    • 基本信息:选择当前实时集成任务的开发负责人运维负责人,并填入当前任务的相应描述,不超过1000个字符。

    • 资源配置:详情请参见实时集成资源配置

步骤三:提交实时集成任务

  1. 单击提交,提交当前实时集成任务。

  2. 提交对话框,输入提交备注信息并单击确定并提交

  3. 完成提交后,在提交对话框中,可查看提交详情。

    如果项目的模式为Dev-Prod,则您需要发布实时集成任务至生产环境。具体操作,请参见管理发布任务

后续步骤

提交或发布任务至生产环境后,您可在运维中心查看并运维实时集成任务,保证任务的正常运行。具体操作,请参见查看并管理实时任务