更新数据集成新版任务,当前支持的任务类型包括:MySQL到Hologres整库实时解决方案。
调试
您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。
授权信息
请求参数
名称 | 类型 | 必填 | 描述 | 示例值 |
---|---|---|---|---|
DIJobId | long | 否 | 任务 ID。 | 11588 |
Description | string | 否 | 任务描述。 | mysql同步到hologres |
ResourceSettings | object | 否 | 资源设置。 | |
OfflineResourceSettings | object | 否 | 离线同步资源。 | |
ResourceGroupIdentifier | string | 否 | 离线同步使用的数据集成资源组标识。 | S_res_group_111_222 |
RealtimeResourceSettings | object | 否 | 实时同步资源。 | |
ResourceGroupIdentifier | string | 否 | 实时同步使用的数据集成资源组标识。 | S_res_group_111_222 |
TransformationRules | array<object> | 否 | 同步对象转换规则定义列表,列表中每个元素为一条转换规则定义。 | |
object | 否 | 同步对象转换规则定义。 | ||
RuleName | string | 否 | 规则名称,当动作类型和动作作用的目标类型相同时,规则名称需保证唯一性。 | rename_rule_1 |
RuleActionType | string | 否 | 动作类型,可选的枚举值:
| Rename |
RuleTargetType | string | 否 | 动作作用的目标类型,可选的枚举值:
| Table |
RuleExpression | string | 否 | 规则表达式,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 时使用 | {"expression":"${srcDatasoureName}_${srcDatabaseName}"} |
TableMappings | array<object> | 否 | 同步对象转换映射列表,列表中每个元素描述了一组源端同步对象选择规则列表和在该组同步对象上应用的同步对象转换规则列表。 | |
object | 否 | 同步对象转换映射。 | ||
SourceObjectSelectionRules | array<object> | 否 | 源端对象选择规则,支持多条。 | |
object | 否 | 每条规则可选择待同步源端对象的不同对象类型,如选择源端数据库、源端数据表。 | ||
ObjectType | string | 否 | 对象类型,可选的枚举值:
| Table |
Expression | string | 否 | 表达式。 | mysql_table_1 |
TransformationRules | array<object> | 否 | 源端对象上应用的转换规则列表。 | |
object | 否 | 源端对象上应用的转换规则。 | ||
RuleName | string | 否 | 规则名称,在一种动作类型+动作作用的目标类型下规则名称唯一。 | rename_rule_1 |
RuleActionType | string | 否 | 动作类型,可选的枚举值:
| Rename |
RuleTargetType | string | 否 | 动作作用的目标类型,可选的枚举值;
| Table |
JobSettings | object | 否 | 同步任务维度的设置,含 DDL 处理策略、源端和目标端列数据类型映射策略、任务运行时参数等。 | |
DdlHandlingSettings | array<object> | 否 | DDL 处理设置,支持多值。 | |
object | 否 | DDL 处理设置。 | ||
Type | string | 否 | DDL 类型,可选的枚举值;
| AddColumn |
Action | string | 否 | 处理动作,可选的枚举值:
| Critical |
ColumnDataTypeSettings | array<object> | 否 | 列类型映射,支持多值。 | |
object | 否 | 列类型映射。 | ||
SourceDataType | string | 否 | 源端类型。 | bigint |
DestinationDataType | string | 否 | 目标端类型。 | text |
RuntimeSettings | array<object> | 否 | 运行时设置,支持多值。 | |
object | 否 | 运行时设置。 | ||
Name | string | 否 | 设置名称,可选的枚举值:
| runtime.offline.concurrent |
Value | string | 否 | 设置取值。 | 1 |
返回参数
示例
正常返回示例
JSON
格式
{
"RequestId": "AAC30B35-820D-5F3E-A42C-E96BB6379325"
}
错误码
HTTP status code | 错误码 | 错误信息 | 描述 |
---|---|---|---|
429 | Throttling.Api | The request for this resource has exceeded your available limit. | 对该资源的请求已超过您的可用上限。 |
429 | Throttling.System | The DataWorks system is busy. Try again later. | DataWorks系统繁忙,请稍后再试。 |
429 | Throttling.User | Your request is too frequent. Try again later. | 您的请求过于频繁,请尝试放缓请求速度。 |
500 | InternalError.System | An internal system error occurred. Try again later. | 系统内部错误,请稍后再试。 |
500 | InternalError.UserId.Missing | An internal system error occurred. Try again later. | 系统内部错误,请稍后再试。 |
访问错误中心查看更多错误码。
变更历史
变更时间 | 变更内容概要 | 操作 |
---|---|---|
2024-06-04 | OpenAPI 错误码发生变更 | 查看变更详情 |
2024-01-18 | OpenAPI 错误码发生变更 | 查看变更详情 |