CreateDataFlowTask - Cloud Parallel File Storage: Central de Documentação do Alibaba Cloud

Cria uma tarefa de fluxo de dados.

Descrição da operação

Notas de uso para CPFS
- Apenas 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 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 houver uma grande quantidade de dados, divida os dados em várias tarefas.
- Você só pode criar uma tarefa de fluxo de dados em um fluxo de dados que esteja 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 do caminho absoluto do arquivo a ser exportado do CPFS não exceda 1.023 caracteres.
Notas de uso para CPFS for Lingjun
- Apenas 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 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 houver uma grande quantidade de dados, divida os dados em várias tarefas.
- Você só pode criar uma tarefa de fluxo de dados em um fluxo de dados que esteja no estado Running.
- Ao criar uma tarefa de exportação, certifique-se de que o comprimento total do caminho absoluto do arquivo a ser exportado do CPFS for Lingjun não exceda 1.023 caracteres.
- O CPFS for Lingjun suporta dois tipos de tarefa: tarefas em lote e tarefas de streaming. Para mais informações, consulte Visão geral dos 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

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: deve começar com `cpfs-`, como cpfs-125487**. CPFS for Lingjun: 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	Ao especificar SrcTaskId, insira o ID da tarefa de fluxo de dados. O sistema copia as informações dos parâmetros TaskAction, DataType e EntryList da tarefa de fluxo de dados especificada, portanto, você não precisa especificar esses parâmetros separadamente. Nota Tarefas de streaming de fluxo de dados não são suportadas.	task-29ee8e890f45****
ClientToken	string	Não	O token do cliente usado para garantir a idempotência da solicitação. Você pode usar o cliente para gerar o token, mas deve garantir que o token seja exclusivo entre diferentes solicitações. O token 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 pode ser diferente para cada solicitação de API.	123e4567-e89b-12d3-a456-42665544****
DryRun	boolean	Não	Especifica se deve ser realizado um dry run. O dry run verifica a validade dos parâmetros e a disponibilidade de recursos sem realmente criar a instância ou gerar cobranças. Valores válidos: true: realiza um dry run sem criar a instância. O sistema verifica os parâmetros obrigatórios, o formato da solicitação, os limites de serviço e o inventário do File Storage NAS. Se a solicitação falhar no dry run, o erro correspondente será retornado. Se a solicitação passar no dry run, o código de status HTTP 200 será retornado, mas TaskId estará vazio. false (padrão): realiza um dry run e envia a solicitação. Se a solicitação passar no dry run, a instância será criada.	false.
TaskAction	string	Não	O tipo de nó do fluxo de dados. Valores válidos: Import: importação de dados do armazenamento de origem para o CPFS. Export: exporta dados especificados do CPFS para o armazenamento de origem. StreamImport: importação de dados em lote do armazenamento de origem para o CPFS. StreamExport: exporta dados especificados em lote do CPFS para o armazenamento de origem. Evict: libera blocos de dados de arquivos no CPFS. Após a liberação, apenas os metadados são retidos no CPFS. Você ainda pode consultar o arquivo, 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 do armazenamento de origem sob demanda. Inventory: obtém a lista de verificação de arquivos gerenciados pelo fluxo de dados no CPFS, que 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 : exporta dados especificados em lote do CPFS para o armazenamento de origem. Import : importação de dados do armazenamento de origem para o CPFS. StreamImport : importa dados especificados em lote do armazenamento de origem para o CPFS. Export : exporta dados especificados do CPFS para o armazenamento de origem. Evict : libera blocos de dados de arquivos no CPFS, retendo apenas metadados após a liberação. Inventory : obtém a lista de arquivos gerenciados pelo fluxo de dados no CPFS, que 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 carimbo de data/hora, propriedade, permissão e outros atributos. Se você selecionar Metadata, apenas os metadados dos arquivos serão importados. Você pode visualizar o arquivo, mas ao acessar os dados do arquivo, os dados são carregados do armazenamento de origem sob demanda. 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 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 (/). Apenas um diretório pode ser especificado 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. Directory, EntryList e TransferFileListPath são parâmetros mutuamente exclusivos. Você pode especificar apenas um deles.	/path_in_cpfs/
EntryList	string	Não	A lista de arquivos nos quais a tarefa de fluxo de dados é executada. 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 está no formato JSON. O caminho de cada arquivo deve ter 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 OSS. Quando TaskAction está definido como Export, cada elemento na lista representa um caminho de arquivo CPFS. Nota Directory, EntryList e TransferFileListPath são parâmetros mutuamente exclusivos. Você pode especificar apenas um deles.	["/path_in_cpfs/file1", "/path_in_cpfs/file2"]
TransferFileListPath	string	Não	O diretório OSS. Os dados são sincronizados com base no conteúdo dos arquivos CSV no diretório 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 TransferFileListPath, Directory e EntryList são parâmetros mutuamente exclusivos. Você pode especificar apenas um deles. Este parâmetro especifica um caminho existente no OSS. Os arquivos *.csv no caminho são armazenados no OSS. TransferFileListPath suporta apenas Import e Export. No cenário de Import, os arquivos ou diretórios especificados nos arquivos CSV são importados do OSS para o CPFS. No cenário de Export, os arquivos ou diretórios especificados nos arquivos CSV são exportados do CPFS para o OSS. O formato do arquivo CSV deve incluir as colunas Name e Type. Name é um caminho relativo, e Type suporta dois valores: dir e file. Se Type for dir, o valor de Name deve terminar com uma barra (/). Apenas o CPFS for Lingjun suporta este recurso.	/test_oss_path/
Includes	string	Não	Filtra diretórios sob o diretório especificado e transfere o conteúdo das pastas incluídas. Nota Este parâmetro entra em vigor apenas quando o parâmetro Directory é especificado. O caminho de cada pasta deve ter de 1 a 1.023 caracteres de comprimento e deve começar e terminar com uma barra (/). O comprimento total não deve exceder 3.000 caracteres. Apenas 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 (/). /../ não é suportado. O valor deve ter de 1 a 1.023 caracteres de comprimento. O valor deve ser codificado em UTF-8. Apenas um diretório pode ser especificado 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: a criação automática da pasta é ativada. false (padrão): a criação automática da pasta não é ativada. Nota Este parâmetro entra em vigor quando TaskAction está definido como Import. Apenas o CPFS for Lingjun 2.6.0 e versões posteriores suportam este recurso.	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 a hora de atualização e mantém a versão mais recente. OVERWRITE_EXISTING: substitui forçadamente arquivos com o mesmo nome. Nota Este parâmetro é obrigatório quando o tipo de sistema de arquivos é CPFS for Lingjun.	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 atual não suporta esta versão do sistema de arquivos.
403	OperationDenied.InvalidState	The operation is not permitted when the status is processing.	O estado atual do sistema de arquivos não suporta esta operação.
403	OperationDenied.DependencyViolation	The operation is denied due to dependancy violation.	As condições para esta operação não foram atendidas.
403	OperationDenied.DataFlowNotSupported	The operation is not supported.	O sistema de arquivos não suporta dataflow.
404	InvalidParameter.InvalidFormat	The EntryList format is invalid.	O formato do EntryList especificado não atende aos requisitos.
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 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 a ser copiada especificado é inválido.
404	InvalidSrcTaskId.TaskIdNotFound	Source task ID is not found.	O ID da tarefa a ser copiada 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.