查詢異步任務(wù)結(jié)果。
接口說明
DataWorks 目前僅支持直接使用 CreateDISyncTask 接口創(chuàng)建或 UpdateDISyncTask 接口更新數(shù)據(jù)集成離線同步任務(wù),而數(shù)據(jù)集成實(shí)時(shí)同步任務(wù)則需要先調(diào)用 GenerateDISyncTaskConfigForCreating 、 GenerateDISyncTaskConfigForUpdating 和 QueryDISyncTaskConfigProcessResult 接口,獲取異步生成創(chuàng)建或更新數(shù)據(jù)集成同步任務(wù)需要的參數(shù),再將該參數(shù)作為 CreateDISyncTask 或 UpdateDISyncTask 接口的入?yún)ⅲ褂?CreateDISyncTask 創(chuàng)建、UpdateDISyncTask 更新相應(yīng)的實(shí)時(shí)同步任務(wù)。 僅支持使用異步方式創(chuàng)建或更新數(shù)據(jù)集成實(shí)時(shí)同步任務(wù)。
調(diào)試
您可以在OpenAPI Explorer中直接運(yùn)行該接口,免去您計(jì)算簽名的困擾。運(yùn)行成功后,OpenAPI Explorer可以自動(dòng)生成SDK代碼示例。
授權(quán)信息
請(qǐng)求參數(shù)
名稱 | 類型 | 必填 | 描述 | 示例值 |
---|---|---|---|---|
ProjectId | long | 是 | DataWorks 工作空間的 ID。您可以登錄 DataWorks 控制臺(tái),進(jìn)入工作空間配置頁(yè)面獲取工作空間 ID。 該參數(shù)用來確定本次 API 調(diào)用操作使用的 DataWorks 工作空間。 | 10000 |
TaskType | string | 是 | 異步方式創(chuàng)建或更新的同步任務(wù)的任務(wù)類型。取值如下:
| DI_REALTIME |
AsyncProcessId | long | 是 | 異步線程的 ID。您可以調(diào)用 GenerateDISyncTaskConfigForCreating 或 GenerateDISyncTaskConfigForUpdating 接口獲取 ID。
| 10 |
返回參數(shù)
示例
正常返回示例
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\"}]}}"
}
}
錯(cuò)誤碼
HTTP status code | 錯(cuò)誤碼 | 錯(cuò)誤信息 | 描述 |
---|---|---|---|
400 | Param.Invalid | The parameter is invalid. | 參數(shù)錯(cuò)誤 |
403 | Forbidden.Access | Access is forbidden. | - |
500 | InternalError.System | An internal error occurred. | 內(nèi)部報(bào)錯(cuò) |
訪問錯(cuò)誤中心查看更多錯(cuò)誤碼。