配置 LAS 数据源

湖仓一体分析服务 （LAS）数据源，通过数据集成同步任务，为您提供离线任务的读取和写入 LAS、实时任务写入 LAS的能力，实现不同数据源与 LAS 之间的数据传输。
本文将为您介绍 LAS 数据同步的能力支持情况。

1 使用前提

1. 子账号新建数据源时，需要有项目的管理员角色，方可以进行新建数据源操作。各角色对应权限说明，详见：管理成员
2. 数据源配置时填写的 AK、SK 信息，需要有 LAS Schema 的 read、write 或 Developer（同时拥有读写）权限：
   1. 登录 LAS 控制台。
   2. 在左侧导航栏中，单击权限管理按钮，进入权限管理界面。
   3. 在权限管理界面，切换至数据权限页签，单击右侧授予权限按钮，根据实际场景，为 AK\SK 对应的子用户，授予 read、write 或 Developer（同时拥有读写）权限。
      添加权限操作详见权限管理。
      

2 使用限制

DataSail 目前前仅支持离线读、离线写和实时写入 LAS 能力。

3 支持的字段类型

4 数据同步任务开发

4.1 数据源注册

新建数据源操作详见配置数据源，以下为您介绍 LAS 数据源配置相关信息：

4.2 新建任务

LAS 数据源测试连通性成功后，进入到数据开发界面，开始新建 LAS 相关通道任务。
新建任务方式详见离线数据同步、流式数据同步。

4.3 可视化配置说明

任务创建成功后，您可根据实际场景，配置 LAS 批式读、LAS 批式写、LAS 流式写等通道任务。

4.3.1 LAS 批式读

数据来源端选择 LAS，并完成以下相关参数配置：
其中参数名称前带 * 的为必填参数，名称前未带 * 的为可选填参数。

4.3.2 LAS 批式写

LAS 批式写目标端配置与批示读端配置一致，详见上方读端配置说明。

4.3.3 LAS 流式写

流式任务写入 LAS，数据目标端选择 LAS，并完成以下相关参数配置：
其中参数名称前带 * 的为必填参数，名称前未带 * 的为可选填参数。

4.3.4 字段映射

数据来源和目标端配置完成后，需要指定来源和目标端的字段映射关系，根据字段映射关系，数据集成任务将源端字段中的数据，写入到目标端对应字段中。
您可通过以下三种方式操作字段映射关系：

• 自动添加：单击自动添加按钮，根据两端数据表信息，可以自动填充来源和目标的字段信息。
• 手动添加：单击手动添加按钮，可以手动编辑来源和目标的字段信息，可以逐个添加。
• 移动\删除字段：您也可以根据需要移动字段映射顺序或删除字段。

4.4 DSL 配置说明

LAS 数据源支持使用脚本模式（DSL）的方式进行配置。
在某些复杂场景下，或当数据源类型暂不支持可视化配置时，您可通过任务脚本的方式，按照统一的 Json 格式，编写 LAS Reader 和 LAS Writer 参数脚本代码，来运行数据集成任务。

4.4.1 进入 DSL 模式

进入 DSL 模式操作流程，可详见 MySQL 数据源-4.4.1 进入DSL 模式。

4.4.2 LAS Reader

进入 DSL 模式编辑界面后，您可根据实际情况替换相应参数，LAS Reader 脚本示例如下：

{
    // [required] dsl version, suggest to use latest version
    "version": "0.2",
    // [required] exection mode, supoort streaming / batch now
    "type": "batch",
    // reader config
    "reader": {
        "type": "las_volc",
        "datasource_id": 13128,
        "parameter": {
            "partition": "date=20230222",
            "reader_parallelism_num": 2,
            "table_name": "source_table",
            "columns": [
                {
                    "name": "id",
                    "type": "string"
                }
            ]
        }
    },
    // writer config
    "writer": {
        ...
    },
    // common config
    "common": {
        ...
    }
}

Reader 参数说明，其中参数名称前带 * 的为必填参数，名称前未带 * 的为可选填参数：

4.4.3 LAS Writer

根据实际情况替换 LAS Writer 相应参数，脚本示例如下：

{
    // [required] dsl version, suggest to use latest version
    "version": "0.2",
    // [required] exection mode, supoort streaming / batch now
    "type": "batch",
    // reader config
    "reader": {
        ...
    },
    // writer config
    "writer": {
        "type": "las",
        "datasource_id": 13128,
        "parameter": {
            "table_name": "target_table",
            "partition": "date=${date},city_temp='3'",
            "columns": [
                {
                    "name": "id",
                    "type": "string"
                }
            ],
            "job.writer.write_mode":"overwrite"
        }
    },
    // common config
    "common": {
        ...
    }
}

Writer 参数说明，其中参数名称前带 * 的为必填参数，名称前未带 * 的为可选填参数：

5 高级参数说明

• 对于可视化通道任务，读参数需要加上 job.reader. 前缀，写参数需要加上 job.writer. 前缀，如下图所示：
  

• 对于 DSL 任务，读参数请配置到 reader.parameter 下，写参数请配置到 writer.parameter 下，直接输入参数名称和参数值。如下图所示：
  

• 批式写 LAS 支持以下高级参数，您可根据实际情况进行配置：

  参数名	描述	默认值
  ob.writer.write_mode	LAS 的数据写入模式，写入方式支持 insert、overwrite。 注意 写入模式仅对批式写入 LAS 有效。	overwrite