インポートタスクを作成します。このタスクには、データソース、ノード、およびテーブルのインポートパッケージが含まれます。
操作説明
インポートパッケージは事前にアップロードする必要があります。アップロード方法の例を以下に示します。
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);
...
今すぐお試しください
テスト
RAM 認証
|
アクション |
アクセスレベル |
リソースタイプ |
条件キー |
依存アクション |
|
dataworks:* |
update |
*All Resource
|
なし | なし |
リクエストパラメーター
|
パラメーター |
型 |
必須 / 任意 |
説明 |
例 |
| 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 用リソースグループのマッピング。マッピング内のキーと値は、それぞれリソースグループの識別子です。次の形式でマッピングを指定します。 |
{"SCHEDULER_RESOURCE_GROUP": {"xxx":"yyy"},"DI_RESOURCE_GROUP":{"ccc":"ddd"}} |
| WorkspaceMap |
string |
任意 |
ソースワークスペースと送信先ワークスペースの名前のプレフィックス間のマッピング。システムがインポート操作を実行する際、インポートパッケージ内のソースワークスペース名のプレフィックスは、このマッピングに基づいて置き換えられます。 |
{"test_workspace_src": "test_workspace_target"} |
| CalculateEngineMap |
string |
任意 |
ソースコンピュートエンジンインスタンスと送信先コンピュートエンジンインスタンスのマッピング。サポートされるコンピュートエンジンインスタンスの種類は、MaxCompute、E-MapReduce (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。この ID は、インポートタスクを実行する場合や、その実行状況を取得する場合の入力パラメーターとして使用されます。 |
123456 |
| ErrorMessage |
string |
エラーメッセージ。 |
test error message |
| RequestId |
string |
リクエスト ID。この ID を使用して、ログの検索および障害のトラブルシューティングを行います。 |
ADFASDFASDFA-ADFASDF-ASDFADSDF-AFFADS |
| ErrorCode |
string |
エラーコード。 |
110001123456 |
| Success |
boolean |
リクエストが成功したかどうかを示します。 |
true |
例
成功レスポンス
JSONJSON
{
"HttpStatusCode": 200,
"Data": 123456,
"ErrorMessage": "test error message",
"RequestId": "ADFASDFASDFA-ADFASDF-ASDFADSDF-AFFADS",
"ErrorCode": "110001123456",
"Success": true
}
エラーコード
完全なリストについては、「エラーコード」をご参照ください。
変更履歴
完全なリストについては、「変更履歴」をご参照ください。