查詢非同步任務結果。
介面說明
DataWorks 目前僅支援直接使用 CreateDISyncTask 介面建立或 UpdateDISyncTask 介面更新Data Integration離線同步任務，而Data Integration即時同步任務則需要先調用 GenerateDISyncTaskConfigForCreating 、 GenerateDISyncTaskConfigForUpdating 和 QueryDISyncTaskConfigProcessResult 介面，擷取非同步產生建立或更新Data Integration同步任務需要的參數，再將該參數作為 CreateDISyncTask 或 UpdateDISyncTask 介面的入參，使用 CreateDISyncTask 建立、UpdateDISyncTask 更新相應的即時同步任務。 僅支援使用非同步方式建立或更新Data Integration即時同步任務。
調試
您可以在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 |
擷取非同步產生或更新Data Integration同步任務所需參數的返回結果。 |
|
| Status |
string |
擷取非同步產生或更新Data Integration同步任務所需參數的結果狀態。取值如下：
|
success |
| Message |
string |
擷取非同步產生或更新Data Integration同步任務所需參數失敗的原因描述。如果擷取成功，則該參數的傳回值為空白。 |
fileId:[100] is invalid. |
| TaskContent |
string |
非同步線程產生的Data Integration同步任務所需參數。該參數將作為 CreateDISyncTask 或 UpdateDISyncTask 介面的輸入參數，用於後續建立或更新Data Integration同步任務。 |
{"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. |
訪問錯誤中心查看更多錯誤碼。
變更歷史
更多資訊，參考變更詳情。