查询异步任务结果。
接口说明
DataWorks 目前仅支持直接使用 CreateDISyncTask 接口创建或 UpdateDISyncTask 接口更新数据集成离线同步任务，而数据集成实时同步任务则需要先调用 GenerateDISyncTaskConfigForCreating 、 GenerateDISyncTaskConfigForUpdating 和 QueryDISyncTaskConfigProcessResult 接口，获取异步生成创建或更新数据集成同步任务需要的参数，再将该参数作为 CreateDISyncTask 或 UpdateDISyncTask 接口的入参，使用 CreateDISyncTask 创建、UpdateDISyncTask 更新相应的实时同步任务。 仅支持使用异步方式创建或更新数据集成实时同步任务。
调试
您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。
调试
授权信息
请求参数
|
名称 |
类型 |
必填 |
描述 |
示例值 |
| ProjectId |
integer |
是 |
DataWorks 工作空间的 ID。您可以登录 DataWorks 控制台，进入工作空间配置页面获取工作空间 ID。 该参数用来确定本次 API 调用操作使用的 DataWorks 工作空间。 |
10000 |
| TaskType |
string |
是 |
异步方式创建或更新的同步任务的任务类型。取值如下：
枚举值：
|
DI_REALTIME |
| AsyncProcessId |
integer |
是 |
异步线程的 ID。您可以调用 GenerateDISyncTaskConfigForCreating 或 GenerateDISyncTaskConfigForUpdating 接口获取 ID。
|
10 |
返回参数
|
名称 |
类型 |
描述 |
示例值 |
|
object |
返回结果。 |
||
| Success |
boolean |
请求是否成功。取值如下：
|
true |
| RequestId |
string |
请求 ID。用于定位日志，排查问题。 |
0bc1411515937635973**** |
| Data |
object |
获取异步生成或更新数据集成同步任务所需参数的返回结果。 |
|
| Status |
string |
获取异步生成或更新数据集成同步任务所需参数的结果状态。取值如下：
|
success |
| Message |
string |
获取异步生成或更新数据集成同步任务所需参数失败的原因描述。如果获取成功，则该参数的返回值为空。 |
fileId:[100] is invalid. |
| TaskContent |
string |
异步线程生成的数据集成同步任务所需参数。该参数将作为 CreateDISyncTask 或 UpdateDISyncTask 接口的输入参数，用于后续创建或更新数据集成同步任务。 |
{"extend":{"mode":"migration_holo","resourceGroup":"280749","name":"h"},"type":"job","steps":[{"stepType":"mysql","parameter":{"connection":[{"datasourceType":"mysql","datasource":"mm","selectedTables":[{"schema":[{"tableInfos":[{"enable":true,"table":"m_v1","tableName":"m_v1"}]}],"dbName":"m"}]}]},"name":"reader","category":"reader"},{"stepType":"holo","parameter":{"datasource":"h","tableMappingRule":{"datasource":[{"tableRule":[{"srcTable":"m_v1","mergeIntoCycleType":"DEFAULT","hourDeltaEnable":false,"dstTable":"m.m_v1","dayDeltaEnable":false,"primaryKeyInfo":{"column":["id"],"type":"pk"},"dstCreateTableInfo":{"indexType":"m_v1","dataColumn":[{"columnSize":0,"name":"id","index":0,"comment":"","newDigit":0,"type":"int8","digit":0,"primaryKey":true}],"schemaName":"m","tableName":"m_v1"},"srcDbName":"m"}],"srcDatasourceName":"mm"}],"totalTableMapping":1},"writeMode":"replay"},"name":"writer","category":"writer"}],"version":"2.0","order":{"hops":[{"from":"reader","to":"writer"}]}} |
示例
正常返回示例
JSON格式
{
"Success": true,
"RequestId": "0bc1411515937635973****",
"Data": {
"Status": "success",
"Message": "fileId:[100] is invalid.",
"TaskContent": "{\"extend\":{\"mode\":\"migration_holo\",\"resourceGroup\":\"280749\",\"name\":\"h\"},\"type\":\"job\",\"steps\":[{\"stepType\":\"mysql\",\"parameter\":{\"connection\":[{\"datasourceType\":\"mysql\",\"datasource\":\"mm\",\"selectedTables\":[{\"schema\":[{\"tableInfos\":[{\"enable\":true,\"table\":\"m_v1\",\"tableName\":\"m_v1\"}]}],\"dbName\":\"m\"}]}]},\"name\":\"reader\",\"category\":\"reader\"},{\"stepType\":\"holo\",\"parameter\":{\"datasource\":\"h\",\"tableMappingRule\":{\"datasource\":[{\"tableRule\":[{\"srcTable\":\"m_v1\",\"mergeIntoCycleType\":\"DEFAULT\",\"hourDeltaEnable\":false,\"dstTable\":\"m.m_v1\",\"dayDeltaEnable\":false,\"primaryKeyInfo\":{\"column\":[\"id\"],\"type\":\"pk\"},\"dstCreateTableInfo\":{\"indexType\":\"m_v1\",\"dataColumn\":[{\"columnSize\":0,\"name\":\"id\",\"index\":0,\"comment\":\"\",\"newDigit\":0,\"type\":\"int8\",\"digit\":0,\"primaryKey\":true}],\"schemaName\":\"m\",\"tableName\":\"m_v1\"},\"srcDbName\":\"m\"}],\"srcDatasourceName\":\"mm\"}],\"totalTableMapping\":1},\"writeMode\":\"replay\"},\"name\":\"writer\",\"category\":\"writer\"}],\"version\":\"2.0\",\"order\":{\"hops\":[{\"from\":\"reader\",\"to\":\"writer\"}]}}"
}
}错误码
|
HTTP status code |
错误码 |
错误信息 |
描述 |
|---|---|---|---|
| 400 | Param.Invalid | The parameter is invalid. | 参数错误 |
| 500 | InternalError.System | An internal error occurred. | 内部报错 |
| 403 | Forbidden.Access | Access is forbidden. |
访问错误中心查看更多错误码。
变更历史
更多信息，参考变更详情。