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 do CPFS

    • Somente o CPFS 2.2.0 e versões posteriores suportam fluxos 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 concluir uma tarefa depende da quantidade de dados a serem importados ou exportados. Para uma grande quantidade de dados, 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 colocada na fila.

    • 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 do CPFS for Lingjun

    • Somente o CPFS for Lingjun 2.4.0 e versões posteriores suportam fluxos 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 concluir uma tarefa depende da quantidade de dados a serem importados ou exportados. Para uma grande quantidade de dados, 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.

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

  • 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

As 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 e 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 ajuda a verificar a validade dos parâmetros e o inventário. Ele não cria a instância nem gera cobranças.

Valores válidos:

  • true: Envia uma solicitação de verificação e não cria a instância. O sistema verifica se os parâmetros obrigatórios foram especificados, o formato da solicitação, os limites de negócios e o inventário do NAS. Se a verificação falhar, o erro correspondente será retornado. Se a verificação for bem-sucedida, o código de status HTTP 200 será retornado, mas o TaskId estará vazio.

  • false: Envia uma solicitação normal e cria a instância diretamente após a verificação ser bem-sucedida. Valor padrão: false.

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: importa dados especificados em lotes 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, 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 do armazenamento de origem.

  • Inventory: obtém a lista de verificação dos arquivos gerenciados por fluxos de dados no CPFS. Isso fornece o status de cache dos arquivos nos fluxos 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.

  • Preload :

    Pré-carrega dados.

  • 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, apenas os metadados dos arquivos são retidos no CPFS.

  • Inventory :

    Obtém o inventário dos arquivos gerenciados por fluxos de dados no CPFS e fornece o status de cache dos arquivos nos fluxos de dados.

Import

DataType

string

Não

O tipo de dados operado pela tarefa de fluxo de dados.

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ê só poderá visualizar os arquivos. Ao acessar os dados do arquivo, os dados são carregados sob demanda do armazenamento de origem.

  • Data: os blocos de dados dos arquivos.

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

Nota

Quando TaskAction é 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 valor deve ter de 1 a 1.023 caracteres de comprimento.

  • O valor deve ser 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 é definido como Export, o diretório deve ser um caminho relativo dentro de FileSystemPath.

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

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

  • Quando TaskAction é 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 para a tarefa de fluxo de dados executar.

Limites:

  • O valor deve ser codificado em UTF-8.

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

  • A lista de arquivos deve estar no formato JSON.

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

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

  • Quando TaskAction é 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 valor deve ter de 1 a 1.023 caracteres de comprimento.

  • O valor deve ser 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 deve ser um caminho real no OSS. Os arquivos *.csv sob o caminho são armazenados no OSS.

  • 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 é um caminho relativo. Type suporta dois valores: dir e file. Se Type for definido como dir, o sufixo de Name deve terminar com uma barra (/).

  • Somente o CPFS for Lingjun suporta este recurso.

/test_oss_path/

Includes

string

Não

Filtra os diretórios sob o diretório especificado e transfere o conteúdo das pastas dentro dos diretórios filtrados.

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

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

  • Somente o CPFS for Lingjun suporta este recurso.

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

DstDirectory

string

Não

O diretório de destino mapeado pela tarefa de fluxo de dados. Limites:

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

  • O valor deve ter de 1 a 1.023 caracteres de comprimento.

  • O valor deve ser codificado em UTF-8.

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

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

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

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

  • Quando TaskAction é 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 a pasta não exista. Valores válidos:

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

  • false: Desativa a criação automática da pasta. Valor padrão: false.

Nota
  • Este parâmetro entra em vigor quando TaskAction é 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 de conflito para 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.