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
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
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:
|
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 no qual a tarefa de fluxo de dados opera. Valores válidos:
Nota
Quando TaskAction está 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 na qual a tarefa de fluxo de dados é executada. 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 |
Os diretórios a serem filtrados sob o diretório especificado. O conteúdo das pastas dentro dos diretórios filtrados é transferido. Nota
|
["/test/","/test1/"] |
| DstDirectory |
string |
Não |
O diretório de destino para o qual a tarefa de fluxo de dados mapeia. 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 ela não exista. Valores válidos:
Nota
|
false |
| ConflictPolicy |
string |
Não |
A política para lidar com 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.