更新数据集成新版任务,当前支持的任务类型包括:MySQL到Hologres整库实时、MySQL到Hive整库离线解决方案。
调试
您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。
请求参数
名称 |
类型 |
是否必选 |
示例值 |
描述 |
Action | String | 是 | UpdateDIJob | 系统规定参数。取值:UpdateDIJob。 |
DIJobId | Long | 否 | 11588 | 任务ID。 |
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 | 否 | 同步对象转换规则定义列表,列表中每个元素为一条转换规则定义。 |
|
RuleName | String | 否 | rename_rule_1 | 规则名称,当动作类型和动作作用的目标类型相同时,规则名称需保证唯一性。 |
RuleActionType | String | 否 | Rename | 动作类型,可选的枚举值:
|
RuleTargetType | String | 否 | Table | 动作作用的目标类型,可选的枚举值:
|
RuleExpression | String | 否 | {"expression":"${srcDatasoureName}_${srcDatabaseName}"} | 规则表达式,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时使用 |
TableMappings | Array | 否 | 同步对象转换映射列表,列表中每个元素描述了一组源端同步对象选择规则列表和在该组同步对象上应用的同步对象转换规则列表。 |
|
SourceObjectSelectionRules | Array | 否 | 源端对象选择规则,支持多条。 |
|
ObjectType | String | 否 | Table | 对象类型,可选的枚举值:
|
Expression | String | 否 | mysql_table_1 | 表达式。 |
TransformationRules | Array | 否 | 源端对象上应用的转换规则列表。 |
|
RuleName | String | 否 | rename_rule_1 | 规则名称,在一种动作类型+动作作用的目标类型下规则名称唯一。 |
RuleActionType | String | 否 | Rename | 动作类型,可选的枚举值:
|
RuleTargetType | String | 否 | Table | 动作作用的目标类型,可选的枚举值;
|
JobSettings | Object | 否 | 同步任务维度的设置,含DDL处理策略、源端和目标端列数据类型映射策略、任务运行时参数等。 |
|
DdlHandlingSettings | Array | 否 | DDL处理设置,支持多值。 |
|
Type | String | 否 | AddColumn | DDL类型,可选的枚举值;
|
Action | String | 否 | Critical | 处理动作,可选的枚举值:
|
ColumnDataTypeSettings | Array | 否 | 列类型映射,支持多值。 |
|
SourceDataType | String | 否 | bigint | 源端类型。 |
DestinationDataType | String | 否 | text | 目标端类型。 |
RuntimeSettings | Array | 否 | 运行时设置,支持多值。 |
|
Name | String | 否 | runtime.offline.concurrent | 设置名称,可选的枚举值:
|
Value | String | 否 | 1 | 设置取值。 |
CycleScheduleSettings | Object | 否 | 周期调度设置。 |
|
ScheduleParameters | String | 否 | bizdate=$bizdate | 调度参数。 |
ChannelSettings | String | 否 | {"structInfo":"MANAGED","storageType":"TEXTFILE","writeMode":"APPEND","partitionColumns":[{"columnName":"pt","columnType":"STRING","comment":""}],"fieldDelimiter":""} | 通道相关任务设置,Json String形式。 |
返回数据
名称 |
类型 |
示例值 |
描述 |
RequestId | String | AAC30B35-820D-5F3E-A42C-E96BB6379325 | 请求ID。 |
示例
请求示例
http(s)://[Endpoint]/?Action=UpdateDIJob
&DIJobId=11588
&Description=mysql同步到hologres
&ResourceSettings={"OfflineResourceSettings":{"ResourceGroupIdentifier":"S_res_group_111_222"},"RealtimeResourceSettings":{"ResourceGroupIdentifier":"S_res_group_111_222"}}
&TransformationRules=[{"RuleName":"rename_rule_1","RuleActionType":"Rename","RuleTargetType":"Table","RuleExpression":"{\"expression\":\"${srcDatasoureName}_${srcDatabaseName}\"}"}]
&TableMappings=[{"SourceObjectSelectionRules":[{"ObjectType":"Table","Expression":"mysql_table_1"}],"TransformationRules":[{"RuleName":"rename_rule_1","RuleActionType":"Rename","RuleTargetType":"Table"}]}]
&JobSettings={"DdlHandlingSettings":[{"Type":"AddColumn","Action":"Critical"}],"ColumnDataTypeSettings":[{"SourceDataType":"bigint","DestinationDataType":"text"}],"RuntimeSettings":[{"Name":"runtime.offline.concurrent","Value":"1"}]}
&公共请求参数
正常返回示例
XML
格式
HTTP/1.1 200 OK
Content-Type:application/xml
<UpdateDIJobResponse>
<RequestId>AAC30B35-820D-5F3E-A42C-E96BB6379325</RequestId>
</UpdateDIJobResponse>
JSON
格式
HTTP/1.1 200 OK
Content-Type:application/json
{
"RequestId" : "AAC30B35-820D-5F3E-A42C-E96BB6379325"
}
错误码
HttpCode |
错误码 |
错误信息 |
描述 |
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. | 系统内部错误,请稍后再试。 |
访问错误中心查看更多错误码。
- 本页导读 (1)