Todos os produtos
Search
Central de documentação

Cloud Parallel File Storage:CreateDataFlowTask

Última atualização: Oct 20, 2026

Cria uma tarefa de fluxo de dados.

Descrição da operação

  • Notas de uso para CPFS

    • Somente o CPFS 2.2.0 e versões posteriores suportam fluxo de dados. Você pode visualizar as informações da versão na página de detalhes do sistema de arquivos no console.

    • As tarefas de fluxo de dados são executadas de forma assíncrona. Você pode chamar a operação DescribeDataFlowTasks para consultar o status de execução da tarefa. O tempo necessário para uma tarefa depende da quantidade de dados a serem importados ou exportados. Se o volume de dados for grande, divida os dados em várias tarefas.

    • Você pode criar tarefas de fluxo de dados apenas para fluxos de dados no estado Running.

    • Quando você executa manualmente uma tarefa de fluxo de dados, a tarefa de atualização automática de dados do fluxo de dados é interrompida e fica em espera.

    • Ao criar uma tarefa de exportação, certifique-se de que o comprimento total dos caminhos absolutos dos arquivos a serem exportados do CPFS não exceda 1.023 caracteres.

  • Notas de uso para CPFS for Lingjun

    • Somente o CPFS for Lingjun 2.4.0 e versões posteriores suportam fluxo de dados. Você pode visualizar as informações da versão na página de detalhes do sistema de arquivos no console.

    • As tarefas de fluxo de dados são executadas de forma assíncrona. Você pode chamar a operação DescribeDataFlowTasks para consultar o status de execução da tarefa. O tempo necessário para uma tarefa depende da quantidade de dados a serem importados ou exportados. Se o volume de dados for grande, divida os dados em várias tarefas.

    • Você pode criar tarefas de fluxo de dados apenas para fluxos de dados no estado Running.

    • Ao criar uma tarefa de exportação, certifique-se de que o comprimento total dos caminhos absolutos dos arquivos a serem exportados do CPFS for Lingjun não exceda 1.023 caracteres.

    • O CPFS for Lingjun suporta tarefas em lote e tarefas de streaming. Para mais informações, consulte Tipos de tarefa.

Experimente agora

Experimente esta API no OpenAPI Explorer, sem necessidade de assinatura manual. Chamadas bem-sucedidas geram automaticamente código SDK correspondente aos seus parâmetros. Faça o download com segurança de credenciais integrada para uso local.

Testar

Autorização RAM

A tabela abaixo descreve a autorização necessária para chamar esta API. Você pode defini-la em uma política do Resource Access Management (RAM). As colunas da tabela estão detalhadas abaixo:

  • Ação: As ações que podem ser usadas no elemento Action das instruções de política de permissão do RAM para conceder permissões para executar a operação.

  • API: A API que você pode chamar para executar a ação.

  • Nível de acesso: O nível de acesso predefinido concedido para cada API. Valores válidos: create, list, get, update e delete.

  • Tipo de recurso: O tipo de recurso que suporta autorização para executar a ação. Indica se a ação suporta permissão em nível de recurso. O recurso especificado deve ser compatível com a ação. Caso contrário, a política será ineficaz.

    • Para APIs com permissões em nível de recurso, os tipos de recursos obrigatórios são marcados com um asterisco (*). Especifique o Nome de Recurso Alibaba Cloud (ARN) correspondente no elemento Resource da política.

    • Para APIs sem permissões em nível de recurso, é exibido como Todos os Recursos. Use um asterisco (*) no elemento Resource da política.

  • Chave de condição: As chaves de condição definidas pelo serviço. A chave permite controle granular, aplicando-se somente a ações ou a ações associadas a recursos específicos. Além das chaves de condição específicas do serviço, o Alibaba Cloud fornece um conjunto de chaves de condição comuns aplicáveis a todos os serviços compatíveis com RAM.

  • Ação dependente: As ações dependentes necessárias para executar a ação. Para concluir a ação, o usuário RAM ou a função RAM deve ter permissões para executar todas as ações dependentes.

Ação

Nível de acesso

Tipo de recurso

Chave de condição

Ação dependente

nas:CreateDataFlowTask

create

*DataFlow.

acs:nas:{#regionId}:{#accountId}:filesystem/{#filesystemId}

Nenhuma Nenhuma

Parâmetros da solicitação

Parâmetro

Tipo

Obrigatório

Descrição

Exemplo

FileSystemId

string

Sim

O ID do sistema de arquivos.

  • Para CPFS de uso geral: O ID deve começar com cpfs-, como cpfs-125487****.

  • Para CPFS for Lingjun: O ID deve começar com bmcpfs-, como bmcpfs-0015****.

cpfs-099394bd928c****

DataFlowId

string

Sim

O ID do fluxo de dados.

df-194433a5be31****

SrcTaskId

string

Não

O ID da tarefa de fluxo de dados de origem. Se você especificar SrcTaskId, deverá inserir um ID de tarefa de fluxo de dados. O sistema copia os parâmetros TaskAction, DataType e EntryList da tarefa de fluxo de dados especificada. Você não precisa especificar esses parâmetros separadamente.

Nota

Tarefas de fluxo de dados de streaming não são suportadas.

task-29ee8e890f45****

ClientToken

string

Não

O token de cliente usado para garantir a idempotência da solicitação. Você pode usar o cliente para gerar o valor, mas deve garantir que o valor seja exclusivo entre diferentes solicitações.

O token de cliente pode conter apenas caracteres ASCII e não pode exceder 64 caracteres de comprimento. Para mais informações, consulte Como garantir a idempotência.

Nota

Se você não especificar este parâmetro, o sistema usará automaticamente o RequestId da solicitação de API como ClientToken. O RequestId de cada solicitação de API pode ser diferente.

123e4567-e89b-12d3-a456-42665544****

DryRun

boolean

Não

Especifica se deve ser realizado um dry run na solicitação de criação.

Um dry run verifica se os parâmetros são válidos e se os recursos são suficientes, mas não cria a instância nem gera cobranças.

Valores válidos:

  • true: realiza um dry run sem criar a instância. O sistema verifica se os parâmetros obrigatórios foram especificados, se o formato da solicitação é válido, se os limites de serviço foram atendidos e se o inventário do NAS é suficiente. Se a solicitação falhar no dry run, uma mensagem de erro será retornada. Se a solicitação passar no dry run, o código de status HTTP 200 será retornado e o TaskId estará vazio.

  • false (padrão): envia a solicitação sem realizar um dry run. Se a solicitação passar na verificação, a instância será criada.

false

TaskAction

string

Não

O tipo do nó de fluxo de dados.

Valores válidos:

  • Import: realiza a importação de dados especificados do armazenamento de origem para o CPFS.

  • Export: exporta dados especificados do CPFS para o armazenamento de origem.

  • StreamImport: realiza a importação em lote de dados especificados do armazenamento de origem para o CPFS.

  • StreamExport: realiza a exportação em lote de dados especificados do CPFS para o armazenamento de origem.

  • Evict: libera os blocos de dados dos arquivos no CPFS. Após a liberação dos blocos de dados, apenas os metadados dos arquivos são retidos no CPFS. Você ainda pode consultar os arquivos, mas os blocos de dados são removidos e não ocupam capacidade de armazenamento no CPFS. Ao acessar os dados do arquivo, os dados são carregados sob demanda a partir do armazenamento de origem.

  • Inventory: obtém a lista de verificação dos arquivos gerenciados pelo fluxo de dados no CPFS. Isso fornece o status de cache dos arquivos no fluxo de dados.

Nota

O CPFS for Lingjun suporta apenas Import, Export, StreamImport e StreamExport. StreamImport e StreamExport são suportados apenas no CPFS for Lingjun 2.6.0 e versões posteriores.

Valores válidos:

  • StreamExport :

    Realiza a exportação em lote de dados especificados do CPFS para o armazenamento de origem.

  • Import :

    Realiza a importação de dados especificados do armazenamento de origem para o CPFS.

  • StreamImport :

    Importa dados especificados em lotes do armazenamento de origem para o CPFS.

  • Export :

    Exporta dados especificados do CPFS para o armazenamento de origem.

  • Evict :

    Libera os blocos de dados dos arquivos no CPFS. Após a liberação dos blocos de dados, apenas os metadados dos arquivos são retidos no CPFS.

  • Inventory :

    Obtém o inventário de arquivos gerenciados pelo fluxo de dados no CPFS e fornece o status de cache dos arquivos no fluxo de dados.

Import

DataType

string

Não

O tipo de dados no qual a tarefa de fluxo de dados opera.

Valores válidos:

  • Metadata: os metadados dos arquivos, incluindo atributos como carimbo de data/hora, propriedade e permissão. Se você selecionar Metadata, apenas os metadados dos arquivos serão importados. Você pode visualizar os arquivos, mas ao acessar os dados do arquivo, os dados são carregados sob demanda a partir do armazenamento de origem.

  • Data: os blocos de dados dos arquivos.

  • MetaAndData: os metadados e blocos de dados dos arquivos.

Nota

Quando TaskAction está definido como Evict, o parâmetro DataType é obrigatório.

Valores válidos:

  • :
  • Metadata :

    Os metadados dos arquivos.

  • Data :

    Os blocos de dados dos arquivos.

  • MetaAndData :

    Os metadados e blocos de dados dos arquivos.

Metadata

Directory

string

Não

O diretório de origem dos dados.

Limites:

  • O comprimento é de 1 a 1.023 caracteres.

  • O valor é codificado em UTF-8.

  • O valor deve começar e terminar com uma barra (/).

  • Você pode especificar apenas um diretório por vez.

  • Quando TaskAction está definido como Export, o diretório deve ser um caminho relativo dentro de FileSystemPath.

  • Quando TaskAction está definido como Import, o diretório deve ser um caminho relativo dentro de SourceStoragePath.

  • Quando TaskAction está definido como StreamExport, o diretório deve ser um caminho relativo dentro de FileSystemPath.

  • Quando TaskAction está definido como StreamImport, o diretório deve ser um caminho relativo dentro de SourceStoragePath.

Nota

StreamImport e StreamExport são suportados apenas no CPFS for Lingjun 2.6.0 e versões posteriores. Os parâmetros Directory, EntryList e TransferFileListPath são mutuamente exclusivos. Você pode especificar apenas um deles.

/path_in_cpfs/

EntryList

string

Não

A lista de arquivos na qual a tarefa de fluxo de dados é executada.

Limites:

  • O valor é codificado em UTF-8.

  • O comprimento total da lista de arquivos é inferior a 64 KB.

  • A lista de arquivos está no formato JSON.

  • O caminho de um único arquivo tem de 1 a 1.023 caracteres de comprimento e deve começar com uma barra (/).

  • Quando TaskAction está definido como Import, cada elemento na lista representa um nome de objeto do OSS.

  • Quando TaskAction está definido como Export, cada elemento na lista representa um caminho de arquivo do CPFS.

Nota

Os parâmetros Directory, EntryList e TransferFileListPath são mutuamente exclusivos. Você pode especificar apenas um deles.

["/path_in_cpfs/file1", "/path_in_cpfs/file2"]

TransferFileListPath

string

Não

O diretório do OSS. Os dados são sincronizados com base no conteúdo do arquivo CSV no diretório do OSS. Limites:

  • O valor deve começar e terminar com uma barra (/).

  • O valor diferencia maiúsculas de minúsculas.

  • O comprimento é de 1 a 1.023 caracteres.

  • O valor é codificado em UTF-8.

Nota
  • Os parâmetros TransferFileListPath, Directory e EntryList são mutuamente exclusivos. Você pode especificar apenas um deles.

  • Este parâmetro especifica um caminho real no OSS. Os arquivos *.csv no caminho são armazenados no OSS.

  • O TransferFileListPath suporta apenas as operações Import e Export.

  • No cenário de Import, os arquivos ou diretórios especificados no arquivo CSV são importados do OSS para o CPFS.

  • No cenário de Export, os arquivos ou diretórios especificados no arquivo CSV são exportados do CPFS para o OSS.

  • O arquivo CSV deve conter as colunas Name e Type. Name especifica um caminho relativo. Type suporta dois valores: dir e file. Se Type estiver definido como dir, o valor de Name deve terminar com uma barra (/).

  • Somente o CPFS for Lingjun suporta este recurso.

/test_oss_path/

Includes

string

Não

Os diretórios a serem filtrados sob o diretório especificado. O conteúdo das pastas dentro dos diretórios filtrados é transferido.

Nota
  • Este parâmetro só entra em vigor quando o parâmetro Directory é especificado.

  • O caminho de uma única pasta tem de 1 a 1.023 caracteres de comprimento, deve começar e terminar com uma barra (/) e não pode exceder 3.000 caracteres no comprimento total.

  • Somente o CPFS for Lingjun suporta este recurso.

["/test/","/test1/"]

DstDirectory

string

Não

O diretório de destino para o qual a tarefa de fluxo de dados mapeia. Limites:

  • O valor deve começar e terminar com uma barra (/). O valor não pode conter /../.

  • O comprimento é de 1 a 1.023 caracteres.

  • O valor é codificado em UTF-8.

  • Você pode especificar apenas um diretório por vez.

  • Quando TaskAction está definido como Export, o diretório deve ser um caminho relativo dentro de SourceStoragePath.

  • Quando TaskAction está definido como Import, o diretório deve ser um caminho relativo dentro de FileSystemPath.

  • Quando TaskAction está definido como StreamExport, o diretório deve ser um caminho relativo dentro de SourceStoragePath.

  • Quando TaskAction está definido como StreamImport, o diretório deve ser um caminho relativo dentro de FileSystemPath.

Nota

StreamImport e StreamExport são suportados apenas no CPFS for Lingjun 2.6.0 e versões posteriores.

/path_in_cpfs/

CreateDirIfNotExist

boolean

Não

Especifica se a criação automática da pasta deve ser ativada caso ela não exista. Valores válidos:

  • true: ativa a criação automática da pasta.

  • false (padrão): desativa a criação automática da pasta.

Nota
  • Este parâmetro só entra em vigor quando TaskAction está definido como Import.

  • Este parâmetro é suportado apenas no CPFS for Lingjun 2.6.0 e versões posteriores.

false

ConflictPolicy

string

Não

A política para lidar com arquivos com o mesmo nome. Valores válidos:

  • SKIP_THE_FILE: ignora arquivos com o mesmo nome.

  • KEEP_LATEST: compara o horário de atualização e retém a versão mais recente.

  • OVERWRITE_EXISTING: substitui à força arquivos com o mesmo nome.

Nota

Este parâmetro é obrigatório quando o tipo de sistema de arquivos é CPFS for Lingjun.

Valores válidos:

  • KEEP_LATEST :

    Compara o horário de atualização e retém a versão mais recente.

  • OVERWRITE_EXISTING :

    Substitui à força arquivos com o mesmo nome.

  • SKIP_THE_FILE :

    Ignora arquivos com o mesmo nome.

SKIP_THE_FILE

Elementos de resposta

Elemento

Tipo

Descrição

Exemplo

object

RequestId

string

O ID da solicitação.

2D69A58F-345C-4FDE-88E4-BF518948****

TaskId

string

O ID da tarefa de fluxo de dados.

task-38aa8e890f45****

Exemplos

Resposta de sucesso

JSON formato

{
  "RequestId": "2D69A58F-345C-4FDE-88E4-BF518948****",
  "TaskId": "task-38aa8e890f45****"
}

Códigos de erro

Código de status HTTP

Código de erro

Mensagem de erro

Descrição

400 IllegalCharacters The parameter contains illegal characters. O parâmetro especificado é inválido.
400 MissingFileSystemId FileSystemId is mandatory for this action. O parâmetro FileSystemId não foi especificado.
400 MissingDataFlowId DataFlowId is mandatory for this action. O parâmetro DataFlowId não foi especificado.
400 InvalidFilesystemVersion.NotSupport This Api does not support this fileSystem version. A operação de API atual não oferece suporte a esta versão do sistema de arquivos.
403 OperationDenied.InvalidState The operation is not permitted when the status is processing. Esta operação não é permitida enquanto o recurso estiver no estado de processamento.
403 OperationDenied.DependencyViolation The operation is denied due to dependancy violation. As condições para a execução desta operação não foram atendidas.
403 OperationDenied.DataFlowNotSupported The operation is not supported. O sistema de arquivos não suporta fluxo de dados.
404 InvalidParameter.InvalidFormat The EntryList format is invalid. O formato do parâmetro EntryList especificado é inválido.
404 InvalidParameter.SizeTooLarge The specified EntryList size exceeds 64 KB. O tamanho do EntryList especificado excede 64 KB.
404 InvalidDataFlow.NotFound The specified data flow does not exist. O fluxo de dados especificado não existe.
404 InvalidTaskAction.NotSupported The task action is not supported. O tipo de tarefa especificado não é suportado.
404 InvalidTaskAction.PermissionDenied The task action is not allowed. O tipo de tarefa especificado não é permitido, como a replicação do sistema.
404 InvalidSrcTaskId.NotFound The SrcTaskId is not found. O SrcTaskId especificado não existe.
404 InvalidDataType.NotSupported The data type is not supported. O tipo de dados especificado não é suportado.
404 InvalidSrcTaskId.TaskIdInvalid Source task ID is invalid. O ID da tarefa de replicação especificado é inválido.
404 InvalidSrcTaskId.TaskIdNotFound Source task ID is not found. O ID da tarefa de replicação especificado não existe.

Consulte Códigos de Erro para uma lista completa.

Notas de versão

Consulte Notas de Versão para uma lista completa.