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
Testar
Autorização RAM
|
Ação |
Nível de acesso |
Tipo de recurso |
Chave de condição |
Ação dependente |
|
nas:CreateDataFlowTask |
create |
*DataFlow.
|
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-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:
|
false |
| TaskAction |
string |
Não |
O tipo do nó de fluxo de dados. Valores válidos:
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:
|
Import |
| DataType |
string |
Não |
O tipo de dados operado pela tarefa de fluxo de dados. Valores válidos:
Nota
Quando TaskAction é definido como Evict, o parâmetro DataType é obrigatório. Valores válidos:
|
Metadata |
| Directory |
string |
Não |
O diretório de origem dos dados. Limites:
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:
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:
Nota
|
/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
|
["/test/","/test1/"] |
| DstDirectory |
string |
Não |
O diretório de destino mapeado pela tarefa de fluxo de dados. Limites:
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:
Nota
|
false |
| ConflictPolicy |
string |
Não |
A política de conflito para arquivos com o mesmo nome. Valores válidos:
Nota
Este parâmetro é obrigatório quando o tipo de sistema de arquivos é CPFS for Lingjun. Valores válidos:
|
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.