すべてのプロダクト
Search
ドキュメントセンター

DataWorks:CreateImportMigration

最終更新日:Mar 21, 2026

インポートタスクを作成します。このタスクには、データソース、ノード、およびテーブルのインポートパッケージが含まれます。

操作説明

インポートパッケージは事前にアップロードする必要があります。アップロード方法の例を以下に示します。

    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);
    ...

今すぐお試しください

この API を OpenAPI Explorer でお試しください。手作業による署名は必要ありません。呼び出しに成功すると、入力したパラメーターに基づき、資格情報が組み込まれた SDK コードが自動的に生成されます。このコードをダウンロードしてローカルで使用できます。

テスト

RAM 認証

下表に、この API を呼び出すために必要な認証情報を示します。認証情報は、RAM (Resource Access Management) ポリシーを使用して定義できます。以下で各列名について説明します。

  • アクション:特定のリソースに対して実行可能な操作。ポリシー構文ではAction要素として指定します。

  • API:アクションを具体的に実行するための API。

  • アクセスレベル:各 API に対して事前定義されているアクセスの種類。有効な値:create、list、get、update、delete。

  • リソースタイプ:アクションが作用するリソースの種類。リソースレベルでの権限をサポートするかどうかを示すことができます。ポリシーの有効性を確保するため、アクションの対象として適切なリソースを指定してください。

    • リソースレベルの権限を持つ API の場合、必要なリソースタイプはアスタリスク (*) でマークされます。ポリシーのResource要素で対応する ARN を指定してください。

    • リソースレベルの権限を持たない API の場合、「すべてのリソース」と表示され、ポリシーのResource要素でアスタリスク (*) でマークされます。

  • 条件キー:サービスによって定義された条件のキー。このキーにより、きめ細やかなアクセス制御が可能になります。この制御は、アクション単体に適用することも、特定のリソースに対するアクションに適用することもできます。Alibaba Cloud は、サービス固有の条件キーに加えて、すべての RAM 統合サービスに適用可能な一連の共通条件キーを提供しています。

  • 依存アクション:ある特定のアクションを実行するために、前提として実行が必要となる他のアクション。依存アクションの権限も RAM ユーザーまたは RAM ロールに付与する必要があります。

アクション

アクセスレベル

リソースタイプ

条件キー

依存アクション

dataworks:*

update

*All Resource

*

なし なし

リクエストパラメーター

パラメーター

必須 / 任意

説明

ProjectId

integer

必須

DataWorks ワークスペース ID。DataWorks コンソールにログインし、「ワークスペース」ページに移動して、ワークスペース ID を確認できます。

123456

Name

string

必須

インポートタスクの名前。この名前はワークスペース内で一意である必要があります。

test_import_001

PackageType

string

必須

インポートパッケージの種類。有効な値は以下のとおりです。

  • DATAWORKS_MODEL(標準フォーマット)

  • DATAWORKS_V2(Apsara Stack DataWorks V3.6.1 ~ V3.11)

  • DATAWORKS_V3(Apsara Stack DataWorks V3.12 以降)

DATAWORKS_MODEL

PackageFile

string

必須

インポートパッケージのパス。インポートパッケージは事前にアップロードする必要があります。アップロード方法の例を以下に示します。

        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);

/home/admin/xxx/import.zip

ResourceGroupMap

string

任意

スケジューリング用リソースグループと Data Integration 用リソースグループのマッピング。マッピング内のキーと値は、それぞれリソースグループの識別子です。次の形式でマッピングを指定します。

{
    "SCHEDULER_RESOURCE_GROUP": {
        "xxx": "yyy"
    },
    "DI_RESOURCE_GROUP": {
        "ccc": "dfdd"
    }
}

{"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:リソースの自動コミットを有効にするかどうかを指定します。値 true は有効、false は無効を意味します。

  • resourceAutoDeploy:リソースの自動デプロイを有効にするかどうかを指定します。値 true は有効、false は無効を意味します。

  • functionAutoCommit:関数の自動コミットを有効にするかどうかを指定します。値 true は有効、false は無効を意味します。

  • functionAutoDeploy:関数の自動デプロイを有効にするかどうかを指定します。値 true は有効、false は無効を意味します。

  • tableAutoCommitToDev:テーブルを開発環境に自動コミットするかどうかを指定します。値 true は有効、false は無効を意味します。

  • tableAutoCommitToProd:テーブルを本番環境に自動コミットするかどうかを指定します。値 true は有効、false は無効を意味します。

  • ignoreLock:インポートタスクがロックされている場合に、ロックを自動的に無視するかどうかを指定します。値 true は無視、false は無視しないを意味します。このパラメーターを true に設定すると、タスクがロックされていても強制的に更新できます。

  • fileAutoCommit:ファイルの自動コミットを有効にするかどうかを指定します。値 true は有効、false は無効を意味します。

  • fileAutoDeploy:ファイルの自動デプロイを有効にするかどうかを指定します。値 true は有効、false は無効を意味します。

{ "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
}

エラーコード

完全なリストについては、「エラーコード」をご参照ください。

変更履歴

完全なリストについては、「変更履歴」をご参照ください。