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

Cria uma tarefa de fluxo de dados.

Descrição da operação

Observações sobre o 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. Para grandes volumes de dados, divida os dados em várias tarefas.
- Você pode criar uma tarefa de fluxo de dados apenas em um fluxo 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 do caminho absoluto do arquivo a ser exportado do CPFS não exceda 1.023 caracteres.
Observações sobre o 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. Para grandes volumes de dados, divida os dados em várias tarefas.
- Você pode criar uma tarefa de fluxo de dados apenas em um fluxo de dados 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: 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	Se você 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. Você não precisa especificar esses parâmetros separadamente. Nota As tarefas de streaming de fluxo de dados 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 token, mas certifique-se de 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 valor de RequestId como o valor de ClientToken. O valor de 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 incorrer em taxas. 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 as restrições de negócios são atendidas e se os recursos do NAS são suficientes. 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 (padrão): realiza um dry run e envia a solicitação. Se a verificação for bem-sucedida, a instância será criada.	false
TaskAction	string	Não	O tipo de nó do 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 de 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 do armazenamento de origem sob demanda. Inventory: obtém a lista de verificação dos arquivos gerenciados pelo fluxo de dados no CPFS. A lista de verificação 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 pelo 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, apenas os metadados dos arquivos são retidos no CPFS. Inventory : Obtém a lista de arquivos gerenciados pelo fluxo de dados no CPFS. A lista 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 o carimbo de data/hora, propriedade, permissão e outros atributos. Se você selecionar Metadata, apenas os metadados dos arquivos serão importados. Você pode ver os arquivos, 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 O parâmetro DataType é obrigatório quando TaskAction está definido como Evict. 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. Se TaskAction estiver definido como Export, este diretório deve ser um caminho relativo dentro de FileSystemPath. Se TaskAction estiver definido como Import, este diretório deve ser um caminho relativo dentro de SourceStoragePath. Se TaskAction estiver definido como StreamExport, este diretório deve ser um caminho relativo dentro de FileSystemPath. Se TaskAction estiver definido como StreamImport, este diretório deve ser um caminho relativo dentro de SourceStoragePath. Nota StreamImport e StreamExport são suportados apenas pelo 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 na qual 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 deve estar 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 (/). Se TaskAction estiver definido como Import, cada elemento na lista representa um nome de objeto do OSS. Se TaskAction estiver definido como Export, cada elemento na lista representa um caminho de arquivo do 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 do OSS. Os dados são sincronizados com base no conteúdo dos arquivos 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 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. Para Import, os arquivos ou diretórios especificados nos arquivos CSV são importados do OSS para o CPFS. Para Export, os arquivos ou diretórios especificados nos arquivos 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 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 pode 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. Se TaskAction estiver definido como Export, este diretório deve ser um caminho relativo dentro de SourceStoragePath. Se TaskAction estiver definido como Import, este diretório deve ser um caminho relativo dentro de FileSystemPath. Se TaskAction estiver definido como StreamExport, este diretório deve ser um caminho relativo dentro de SourceStoragePath. Se TaskAction estiver definido como StreamImport, este diretório deve ser um caminho relativo dentro de FileSystemPath. Nota StreamImport e StreamExport são suportados apenas pelo 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): Não cria a pasta automaticamente. 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 parâmetro.	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 mantém a versão mais recente. OVERWRITE_EXISTING: Sobrescreve forçadamente 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 mantém a versão mais recente. OVERWRITE_EXISTING : Sobrescreve forçadamente 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.	Parâmetro 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.	Esta operação não é permitida enquanto o status está sendo processado.
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 fluxos de dados.
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 replicar o 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.