DataWorks:CreateImportMigration

O ID do workspace do DataWorks. Você pode fazer login no console do DataWorks e acessar a página Configuração do Workspace para obter o ID do workspace.

O nome da tarefa de importação a ser criada. O nome deve ser exclusivo no workspace.

O tipo do pacote de importação e exportação. Valores válidos:

• DATAWORKS_MODEL: formato padrão

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

• DATAWORKS_V3: Apsara Stack (V3.12 e posterior)

O caminho do arquivo do pacote de importação. Nota: Esta operação envolve uploads de arquivos. O exemplo a seguir mostra como chamar esta operação:

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

Se você passar diretamente o caminho do arquivo, o valor do parâmetro deve ser uma URL válida de um objeto do OSS na conta do chamador, como https://{bucket}.oss-{region}.aliyuncs.com/{object_key}. URLs do OSS entre contas são rejeitadas. Se você usar o método Advance do SDK, poderá fazer o upload do arquivo usando um fluxo de arquivo local.

O mapeamento entre grupos de recursos de agendamento e grupos de recursos de integração de dados. Tanto as chaves quanto os valores no mapeamento são identificadores de grupos de recursos. O formato é o seguinte:

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

O mapeamento usado para alterar os nomes dos workspaces de entrada e saída no pacote de importação e exportação para os nomes dos workspaces mapeados durante as operações de importação e exportação. Por exemplo, durante uma importação, os prefixos dos nomes dos workspaces de entrada e saída são substituídos com base no mapeamento.

O mapeamento entre os mecanismos de computação de origem e as instâncias do mecanismo de computação de destino na tarefa de importação. Os tipos de mecanismo de computação incluem ODPS, EMR, HADOOP_CDH e HOLOGRES.

As regras para envio e publicação automáticos de tarefas durante a operação de importação. Os parâmetros são os seguintes:

• resourceAutoCommit: Especifica se os recursos devem ser enviados automaticamente. true: sim. false: não.

• resourceAutoDeploy: Especifica se os recursos devem ser publicados automaticamente. true: sim. false: não.

• functionAutoCommit: Especifica se as funções devem ser enviadas automaticamente. true: sim. false: não.

• functionAutoDeploy: Especifica se as funções devem ser publicadas automaticamente. true: sim. false: não.

• tableAutoCommitToDev: Especifica se as tabelas devem ser enviadas automaticamente para o ambiente de desenvolvimento. true: sim. false: não.

• tableAutoCommitToProd: Especifica se as tabelas devem ser enviadas automaticamente para o ambiente de produção. true: sim. false: não.

• ignoreLock: Especifica se os bloqueios devem ser ignorados automaticamente. true: sim. false: não. Se uma tarefa estiver bloqueada por outro usuário para edição, você poderá forçar a atualização da tarefa atual escolhendo ignorar o bloqueio.

• fileAutoCommit: Especifica se os arquivos devem ser enviados automaticamente. true: sim. false: não.

• fileAutoDeploy: Especifica se os arquivos devem ser publicados automaticamente. true: sim. false: não.

A descrição do pacote de importação e exportação.