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
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:
|
|
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:
|
|
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:
|
|
|
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:
|
|
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.