調用CreateImportMigration建立匯入任務,匯入任務包含資料來源資訊、任務、表等對象的DataWorks匯入匯出包。
介面說明
注意:本介面匯入檔案涉及檔案上傳,方式調用舉例如下:
Config config = new Config();
config.setAccessKeyId(accessId);
config.setAccessKeySecret(accessKey);
config.setEndpoint(popEndpoint);
config.setRegionId(regionId);
Client client = new Client(config);
CreateImportMigrationAdvanceRequest request = new CreateImportMigrationAdvanceRequest();
request.setName("test_migration_api_" + System.currentTimeMillis());
request.setProjectId(123456L);
request.setPackageType("DATAWORKS_MODEL");
request.setPackageFileObject(new FileInputStream("/home/admin/Downloads/test.zip"));
RuntimeOptions runtime = new RuntimeOptions();
CreateImportMigrationResponse response = client.createImportMigrationAdvance(request, runtime);
...
調試
您可以在OpenAPI Explorer中直接運行該介面,免去您計算簽名的困擾。運行成功後,OpenAPI Explorer可以自動產生SDK程式碼範例。
調試
授權資訊
|
操作 |
存取層級 |
資源類型 |
條件關鍵字 |
關聯操作 |
|
dataworks:* |
update |
*全部資源
|
無 | 無 |
請求參數
|
名稱 |
類型 |
必填 |
描述 |
樣本值 |
| ProjectId |
integer |
是 |
DataWorks 工作空間的 ID。您可以登入 DataWorks 管控台,進入工作空間配置頁面擷取工作空間 ID。 |
123456 |
| Name |
string |
是 |
建立的匯入任務的名稱。專案空間內該名稱必須唯一。 |
test_import_001 |
| PackageType |
string |
是 |
匯入匯出包的類型,取值如下:
|
DATAWORKS_MODEL |
| PackageFile |
string |
是 |
匯入包檔案路徑。 注意:本介面匯入檔案涉及檔案上傳。方式調用舉例如下: |
/home/admin/xxx/import.zip |
| ResourceGroupMap |
string |
否 |
調度資源群組和Data Integration資源群組的映射關係。映射的 key 和 value 均為資源群組的標識符(identifier), 格式如下: |
{"SCHEDULER_RESOURCE_GROUP": {"xxx":"yyy"},"DI_RESOURCE_GROUP":{"ccc":"ddd"}} |
| WorkspaceMap |
string |
否 |
用於在執行匯入匯出操作時,根據該映射關係,修改匯入匯出包裡的輸入輸出專案空間名稱為映射後的專案空間名稱。例如,匯入時會根據映射關係,把輸入輸出裡的專案空間名稱的首碼做相應替換。 |
{"test_workspace_src": "test_workspace_target"} |
| CalculateEngineMap |
string |
否 |
匯入任務中,匯入的源計算引擎到匯出的目標計算引擎執行個體的映射關係。 計算引擎的類型,包括 ODPS、EMR、HADOOP_CDH、HOLOGRES 等。 |
{ "ODPS": { "zxy_8221431_engine": "wzp_kaifazheban_engine" }, "EMR": { "aaaa": "bbb" } } |
| CommitRule |
string |
否 |
執行匯入操作時,設定的自動認可發布任務的規則。參數如下:
|
{ "resourceAutoCommit": false, "resourceAutoDeploy": false, "functionAutoCommit": false, "functionAutoDeploy": false, "tableAutoCommitToDev": false, "tableAutoCommitToProd": false, "ignoreLock": false, "fileAutoCommit": false, "fileAutoDeploy": false } |
| Description |
string |
否 |
匯入匯出包的描述資訊。 |
test description |
返回參數
|
名稱 |
類型 |
描述 |
樣本值 |
|
object |
返回資料。 |
||
| HttpStatusCode |
integer |
HTTP 狀態代碼。 |
200 |
| Data |
integer |
匯入匯出包 ID。作為後續執行匯入任務或擷取匯入任務執行進度的入參。 |
123456 |
| ErrorMessage |
string |
錯誤資訊。 |
test error message |
| RequestId |
string |
請求的 ID。用於定位日誌,排查問題。 |
ADFASDFASDFA-ADFASDF-ASDFADSDF-AFFADS |
| ErrorCode |
string |
錯誤碼。 |
110001123456 |
| Success |
boolean |
調用是否成功。 |
true |
樣本
正常返回樣本
JSON格式
{
"HttpStatusCode": 200,
"Data": 123456,
"ErrorMessage": "test error message",
"RequestId": "ADFASDFASDFA-ADFASDF-ASDFADSDF-AFFADS",
"ErrorCode": "110001123456",
"Success": true
}
錯誤碼
訪問錯誤中心查看更多錯誤碼。
變更歷史
更多資訊,參考變更詳情。