检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
适用bg。 queue_name 否 String dli数据连接执行sql所需的队列，数据连接类型为DLI时必须填写。 dw_id 是 String 汇总表所在的数据连接ID，为32位十六进制数字。 db_name 是 String 汇总表所在的数据库名。 schema 否 String
场景。数据集成支持的功能主要有： 表/文件/整库迁移 支持批量迁移表或者文件，还支持同构/异构数据库之间整库迁移，一个作业即可迁移几百张表。 增量数据迁移 支持文件增量迁移、关系型数据库增量迁移、HBase增量迁移，以及使用Where条件配合时间变量函数实现增量数据迁移。 事务模式迁移
json数组写入方式为a[0]。由于在字段映射使用源表字段对目标列进行赋值时，数组下标必须从1开始（表示数组的第一个元素），如果误用了下标0，那么作业会运行失败，故发现该问题为赋值数组下标设置错误导致，需重新设置。 图2 原有参数配置 解决方案 修改字段赋值为a[1]，提交作业版本重新启动即可。
对于集群化的数据源（例如MRS、DWS、RDS、MySQL、Oracle、DIS、ECS），使用两套集群资源，两套环境中的数据库、数据库模式（仅DWS需要）和数据表必须保持同名。 对于Serverless服务（例如DLI），两套队列和两套数据库建议通过名称和后缀（开发环境添加后缀“
String 码表字段ID，ID字符串。 code_table_id 否 String 所属码表ID（更新时必填），ID字符串。 ordinal 是 Integer 序号。 name_en 是 String 字段名，英文。 name_ch 是 String 字段名，中文。 description
数据源认证及其他功能配置 用户名 是 数据库的用户名，创建DWS集群时指定的用户名。 密码 是 数据库的访问密码，创建DWS集群时指定的密码。 数据集成配置 数据库名称 是 适用组件勾选数据集成后，呈现此参数。 配置为要连接的数据库名称。 单次请求行数 否 适用组件勾选数据集成后，呈现此参数。
String RDS的访问端口。 通过RDS管理控制台获取访问端口： 登录管理控制台。 单击“关系型数据库服务”，左侧列表选择实例管理。 单击某一个实例名称，进入实例基本信息页面。 在连接信息标签中可以获取到数据库端口。 userName 是 String 数据库的用户名，创建集群的时候，输入的用户名。
0.1 端口 配置为要连接的数据库的端口。 不同的数据库端口不同，请根据具体情况配置。例如： SQLServer默认端口：1433 PostgreSQL默认端口：5432 数据库名称 配置为要连接的数据库名称。 dbname 用户名 待连接数据库的用户。该数据库用户需要有数据表的读写权限，以及对元数据的读取权限。
DimensionLogicTableAttributeVO objects 字段属性。 dw_type String 数据连接类型，对应表所在的数仓类型，取值可以为DWS、MRS_HIVE、POSTGRESQL、MRS_SPARK、CLICKHOUSE、MYSQL、ORACLE和DORIS等。 dw_name
据catalog。 数据库名称 选择数据库。 DLI数据目录如果选择DLI默认的数据目录dli，表示为DLI的数据库和数据表。 DLI数据目录如果选择DLI所绑定的LakeFormation已创建元数据catalog，表示为LakeFormation的数据库和数据表。 队列名称
String 审批人名称。 响应参数 无 请求示例 创建一个作业名称为myJob的作业，作业类型为BATCH，作业调度配置为CRON，作业在目录树上的路径为/myDir，作业运行日志存放的OBS路径为obs://dlf-test-log。 POST /v1/b384b9e9ab9b4ee
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
节点输出的字段值，输出结果类型为String。 本例中，MRS Hive SQL节点返回单字段二维数组，Kafka Client节点发送的数据定义为StringUtil内嵌对象EL表达式，通过此表达式即可分割二维数组，获取MRS Hive SQL节点输出的字段值。 为便于查看最终获得的结果值，本例选择Kafka
参数类型 描述 target_field_id String 目标字段ID，当前表的某个字段，ID字符串。 target_field_name String 目标字段编码。 field_ids String 来源字段ID，多个ID以逗号分隔。 transform_expression
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
启用细粒度认证后，在数据开发组件选择数据库时报错“Failed to obtain the database”怎么办？ 可能原因 数据开发用户不具备DWS Database Access权限。 解决方案 为数据开发用户添加DWS Database Access权限后，再次尝试选择数据库。 父主题： 数据安全
映射名称：新建映射时会自动生成，您也可以修改。 来源模型：本示例选择“sdi”。 源表：本示例选择原始数据表“sdi_taxi_trip_data”，标准出行数据表的数据均来源于该原始数据表。 图30 新建映射 字段映射： 在“字段映射”区域，依次为表中的字段设置源字段，所选择的源字段应与表中的字段代表相同含
示。目的端高级属性无需配置。 字段分隔符：默认值为逗号，本示例需要保留默认值。 使用包围符：由于IMDbURL有的原始数据中包含“,”，需要修改默认值为“是”。 前N行为标题行：默认值为“否”，本示例首行是标题行，修改默认值为“是”，标题行数配置为1。 图8 源端高级属性 单击“
适用bg。 queue_name 否 String dli数据连接执行sql所需的队列，数据连接类型为DLI时必须填写。 dw_id 是 String 汇总表所在的数据连接ID，为32位十六进制数字。 db_name 是 String 汇总表所在的数据库名。 schema 否 String
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
