大数据开发治理平台 DataWorks：CreateDIJob - 创建数据集成新版任务

数据源名称。

数据源属性。

数据源名称。

数据源属性。

离线同步使用的数据集成资源组标识。

实时同步使用的数据集成资源组标识。

规则名称，当动作类型和动作作用的目标类型相同时，规则名称需保证唯一性。

动作类型，可选的枚举值：

• DefinePrimaryKey（定义主键）
• Rename（重命名）
• AddColumn（增加列）
• HandleDml（DML 处理）
• DefineIncrementalCondition（定义增量条件）
• DefineCycleScheduleSettings（定义周期调度设置）
• DefineRuntimeSettings（定义高级配置参数）
• DefinePartitionKey（定义分区列）

动作作用的目标类型，可选的枚举值：

• Table（表）
• Schema（schema）

规则表达式，json string 格式。

重命名规则（Rename）示例： {"expression":"${srcDatasourceName}_${srcDatabaseName}_0922","variables":[{"variableName":"srcDatabaseName","variableRules":[{"from":"fromdb","to":"todb"}]}]}

• expression：为重命名转换规则表达式，表达式内支持变量包括：${srcDatasourceName}（源端数据源名）、${srcDatabaseName}（源端库名）、${srcTableName}（源端表名）。
• variables：为重命名转换规则表达式中各变量的生成规则，参数默认值为对应含义在源端的原始值，可按需定义一组字符串替换规则对原始值进行改写。variableName：变量名，不含${}。variableRules：变量生成规则组，按顺序串行执行替换，from 原始字符串；to 替换后字符串。

在目标端增加指定列并赋值规则（AddColumn）示例： {"columns":[{"columnName":"my_add_column","columnValueType":"Constant","columnValue":"123"}]}

• 如不指定，默认规则为不加列不复制。
• columnName：附加的列名称。
• columnValueType：附加的列取值类型，包括 Constant（常量）、Variable（变量）。
• columnValue：附加的列取值。当 valueType=Constant 时，value 为自定义常量，String 类型。当 valueType=Variable 时，value 为内置变量。内置变量可选值包括：EXECUTE_TIME（执行时间，Long 类型）、DB_NAME_SRC（源端数据库名称，String 类型）、DATASOURCE_NAME_SRC（源端数据源名称，String 类型）、TABLE_NAME_SRC（源端表名，String 类型）、DB_NAME_DEST（目标端数据库名称，String 类型）、DATASOURCE_NAME_DEST（目标端数据源名称，String 类型）、TABLE_NAME_DEST（目标端表名，String 类型）、DB_NAME_SRC_TRANSED（转换后的数据库名称，String 类型）。

指定目标端表的主键列列名（DefinePrimaryKey）示例： {"columns":["ukcolumn1","ukcolumn2"]}

• 如不指定默认使用源端主键列。
• 当目标端为已有表：数据集成系统不会修改目标端表结构，如果指定的主键列不在目标端的列集合中，任务启动会报错提示。
• 当目标端为自动建表：数据集成系统会自动创建目标端表结构，表结构包含定义的主键列。当指定的主键列不在目标端的列集合中时，任务启动会报错提示。

DML 处理规则（HandleDml）示例： {"dmlPolicies":[{"dmlType":"Delete","dmlAction":"Filter","filterCondition":"id > 1"}]}

• 如不指定，默认规则为 Insert、Update、Delete 均为 Normal
• dmlType：DML 操作类型，Insert（插入）、Update（更新）、Delete（删除）
• dmlAction：DML 处理策略，Normal（正常处理）、Ignore（忽略）、Filter（有条件的正常处理，当 dmlType=Update/Delete 时使用）、LogicalDelete（逻辑删除）
• filterCondition：DML 过滤条件，当 dmlAction=Filter 时使用

源端对象选择规则，支持多条。

源端对象上应用的转换规则列表。

DDL 处理设置。

列类型映射。

运行时设置。

需要周期调度的同步类型。取值范围：

• Full：全量
• OfflineIncremental：离线增量

调度参数。

任务配置导入来源。取值范围： Datastudio：数据开发中的同步任务

待导入任务 ID。