Todos los productos
Search
Centro de documentos

:CreateImportMigration

Última actualización: Sep 04, 2026

Crea una tarea de importación que contiene los paquetes de importación de los orígenes de datos, las tareas y las tablas.

Debe cargar previamente el paquete de importación. Ejemplo del método de carga:

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

...

Depuración

OpenAPI Explorer calcula automáticamente el valor de la firma. Para mayor comodidad, se recomienda llamar a esta operación desde OpenAPI Explorer. Esta herramienta genera dinámicamente el código de ejemplo de la operación para diferentes SDK.

Parámetros de solicitud

Parámetro

Tipo

Obligatorio

Ejemplo

Descripción

Action

String

Sí

CreateImportMigration

La operación que se va a ejecutar. Establezca el valor en CreateImportMigration.

ProjectId

Long

Sí

123456

El ID del espacio de trabajo de DataWorks. Inicie sesión en la consola de DataWorks y vaya a la página Workspace para obtener el ID del espacio de trabajo.

Name

String

Sí

test_import_001

El nombre de la tarea de importación. El nombre debe ser único dentro del espacio de trabajo.

PackageType

String

Sí

DATAWORKS_MODEL

El tipo de paquete de importación. Valores válidos:

  • DATAWORKS_MODEL (formato estándar)

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

  • DATAWORKS_V3 (Apsara Stack DataWorks V3.12 y posteriores)

PackageFile

String

Sí

/home/admin/xxx/import.zip

La ruta del paquete de importación.

Debe cargar previamente el paquete de importación. Ejemplo del método de carga:

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

ResourceGroupMap

String

No

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

La asignación entre el resource group para programación y el resource group para Data Integration. Las claves y los valores de la asignación son los identificadores de los resource groups. Especifique la asignación con el siguiente formato:

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

WorkspaceMap

String

No

{"test_workspace_src": "test_workspace_target"}

La asignación entre los prefijos de los nombres de los espacios de trabajo de origen y destino. Durante la importación, el sistema reemplaza el prefijo del nombre del espacio de trabajo de origen en el paquete según esta asignación.

CalculateEngineMap

String

Sí

{ "ODPS": { "zxy_8221431_engine": "wzp_kaifazheban_engine" }, "EMR": { "aaaa": "bbb" } }

La asignación entre la instancia del motor de cómputo de origen y la instancia del motor de cómputo de destino.

Son compatibles los siguientes tipos de instancias de motor de cómputo: MaxCompute, E-MapReduce (EMR), Hadoop CDH y Hologres.

CommitRule

String

Sí

{ "resourceAutoCommit": false, "resourceAutoDeploy": false, "functionAutoCommit": false, "functionAutoDeploy": false, "tableAutoCommitToDev": false, "tableAutoCommitToProd": false, "ignoreLock": false, "fileAutoCommit": false, "fileAutoDeploy": false }

La regla configurada para confirmar y desplegar automáticamente la tarea de importación. La regla contiene los siguientes parámetros:

  • resourceAutoCommit: especifica si los recursos se confirman automáticamente. El valor true indica que sí y false indica que no.

  • resourceAutoDeploy: especifica si los recursos se despliegan automáticamente. El valor true indica que sí y false indica que no.

  • functionAutoCommit: especifica si la función se confirma automáticamente. El valor true indica que sí y false indica que no.

  • functionAutoDeploy: especifica si la función se despliega automáticamente. El valor true indica que sí y false indica que no.

  • tableAutoCommitToDev: especifica si la tabla se confirma automáticamente en el entorno de desarrollo. El valor true indica que sí y false indica que no.

  • tableAutoCommitToProd: especifica si la tabla se confirma automáticamente en el entorno de producción. El valor true indica que sí y false indica que no.

  • ignoreLock: especifica si se ignora automáticamente el bloqueo cuando una tarea de importación está bloqueada. El valor true indica que sí y false indica que no. Si establece este parámetro en true para una tarea de importación, puede actualizar forzosamente la tarea aunque esté bloqueada.

  • fileAutoCommit: especifica si el archivo se confirma automáticamente. El valor true indica que sí y false indica que no.

  • fileAutoDeploy: especifica si el archivo se despliega automáticamente. El valor true indica que sí y false indica que no.

Description

String

No

test description

La descripción del paquete de importación.

Parámetros de respuesta

Parámetro

Tipo

Ejemplo

Descripción

HttpStatusCode

Integer

200

El código de estado HTTP.

Data

Long

123456

El ID de la tarea de importación. Utilice este ID como parámetro de entrada para ejecutar la tarea de importación u obtener su progreso de ejecución.

ErrorMessage

String

test error message

El mensaje de error.

RequestId

String

ADFASDFASDFA-ADFASDF-ASDFADSDF-AFFADS

El ID de la solicitud. Puede usar este ID para localizar registros y solucionar problemas.

ErrorCode

String

110001123456

El código de error.

Success

Boolean

true

Indica si la solicitud se realizó correctamente.

Ejemplos

Solicitudes de ejemplo

http(s)://[Endpoint]/?Action=CreateImportMigration
&ProjectId=123456
&Name=test_import_001
&PackageType=DATAWORKS_MODEL
&PackageFile=/home/admin/xxx/import.zip
&ResourceGroupMap={"SCHEDULER_RESOURCE_GROUP": {"xxx":"yyy"},"DI_RESOURCE_GROUP":{"ccc":"ddd"}}
&WorkspaceMap={"test_workspace_src": "test_workspace_target"}
&CalculateEngineMap={     "ODPS": {       "zxy_8221431_engine": "wzp_kaifazheban_engine"     },     "EMR": {         "aaaa": "bbb"     }   }
&CommitRule={     "resourceAutoCommit": false,     "resourceAutoDeploy": false,     "functionAutoCommit": false,     "functionAutoDeploy": false,     "tableAutoCommitToDev": false,     "tableAutoCommitToProd": false,     "ignoreLock": false,     "fileAutoCommit": false,     "fileAutoDeploy": false   }
&Description=test description
&<Common request parameters>

Respuestas de éxito de ejemplo

Formato XML

HTTP/1.1 200 OK
Content-Type:application/xml

<CreateImportMigrationResponse>
    <HttpStatusCode>200</HttpStatusCode>
    <Data>123456</Data>
    <ErrorMessage>test error message</ErrorMessage>
    <RequestId>ADFASDFASDFA-ADFASDF-ASDFADSDF-AFFADS</RequestId>
    <ErrorCode>110001123456</ErrorCode>
    <Success>true</Success>
</CreateImportMigrationResponse>

Formato JSON

HTTP/1.1 200 OK
Content-Type:application/json

{
  "HttpStatusCode" : 200,
  "Data" : 123456,
  "ErrorMessage" : "test error message",
  "RequestId" : "ADFASDFASDFA-ADFASDF-ASDFADSDF-AFFADS",
  "ErrorCode" : "110001123456",
  "Success" : true
}

Códigos de error

Para obtener una lista de códigos de error, consulte Códigos de error del servicio.

Return ONLY the corrected Mexican Spanish markdown document. No explanations.