Cria uma subtarefa para uma tarefa de streaming de fluxo de dados.
Descrição da operação
Antes de começar
Antes de chamar esta operação, crie recursos na seguinte ordem e certifique-se de que os recursos em cada nível estejam no estado necessário:
- Criar um sistema de arquivos: Crie um sistema de arquivos CPFS for Lingjun no console.
Requisito de estado: O sistema de arquivos deve estar no estado Running.
- Criar um fluxo de dados: Chame CreateDataFlow para criar um fluxo de dados.
Requisito de estado: O fluxo de dados deve estar no estado Running.
- Criar uma tarefa de fluxo de dados: Chame CreateDataFlowTask para criar uma tarefa de importação por streaming (StreamImport) ou exportação por streaming (StreamExport).
Requisito de estado: A tarefa de fluxo de dados deve estar no estado Executing.
Descrição da operação
Apenas o CPFS for Lingjun versão 2.6.0 e posteriores suportam esta operação. Você pode visualizar as informações da versão na página de detalhes do sistema de arquivos no console.
Você só pode criar subtarefas para tarefas de streaming de fluxo de dados que estejam no estado Executing.
As tarefas de streaming de fluxo de dados são executadas de forma assíncrona. Você pode chamar DescribeDataFlowSubTasks para consultar o status de execução de uma tarefa de streaming.
Quando o tipo de tarefa de fluxo de dados é uma tarefa de streaming, o estado Executing indica apenas que você pode criar tarefas de importação por streaming ou exportação por streaming. Não indica que a tarefa de importação ou exportação está em execução.
Experimente agora
Testar
Autorização RAM
|
Ação |
Nível de acesso |
Tipo de recurso |
Chave de condição |
Ação dependente |
|
nas:CreateDataFlowSubTask |
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. |
bmcpfs-370lx1ev9ss27o0**** |
| DataFlowId |
string |
Sim |
O ID do fluxo de dados. |
df-194433a5be31**** |
| DataFlowTaskId |
string |
Sim |
O ID da tarefa de fluxo de dados. Nota
Apenas IDs de tarefas de streaming de fluxo de dados são suportados. |
task-38aa8e890f45**** |
| DryRun |
boolean |
Não |
Especifica se deve ser realizado um dry run para esta solicitação. Um dry run verifica a validade dos parâmetros e a disponibilidade de recursos sem realmente criar uma instância ou gerar cobranças. Valores válidos:
|
false |
| 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 RequestId da solicitação de API como ClientToken. O RequestId pode variar para cada solicitação de API. |
123e4567-e89b-12d3-a456-42665544**** |
| SrcFilePath |
string |
Sim |
O caminho do arquivo de origem. Limites:
|
/test/file.png |
| DstFilePath |
string |
Sim |
O caminho do arquivo de destino. Limites:
|
/mnt/file.png |
| Condition |
object |
Não |
A condição de verificação. As condições especificadas devem passar pela verificação. |
|
| ModifyTime |
integer |
Não |
A hora de modificação como um timestamp UNIX. Unidade: ns. |
1725897600000000000 |
| Size |
integer |
Não |
O tamanho do arquivo. Unidade: bytes. |
68 |
Elementos de resposta
|
Elemento |
Tipo |
Descrição |
Exemplo |
|
object |
|||
| RequestId |
string |
O ID da solicitação. |
A70BEE5D-76D3-49FB-B58F-1F398211A5C3 |
| DataFlowSubTaskId |
string |
O ID da subtarefa de streaming de fluxo de dados. |
subTaskId-370kyfmyknxcyzw**** |
Exemplos
Resposta de sucesso
JSON formato
{
"RequestId": "A70BEE5D-76D3-49FB-B58F-1F398211A5C3",
"DataFlowSubTaskId": "subTaskId-370kyfmyknxcyzw****"
}
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 é 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 status 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 dataflow 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.