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

Consulta as subtarefas em lote de um fluxo de dados.

Descrição da operação

Suportado apenas pelo CPFS for Lingjun 2.6.0 e versões posteriores. Você pode visualizar as informações da versão na página de detalhes do sistema de arquivos no console.

Antes de começar

Antes de chamar esta operação para consultar as subtarefas do fluxo de dados, você deve criar recursos e iniciar tarefas na seguinte ordem:

Criar um sistema de arquivos bmcpfs: Você deve criar um sistema de arquivos CPFS for Lingjun no console e aguardar até que seu status mude para Running.
Criar uma regra de fluxo de dados: Chame a operação CreateDataFlow no sistema de arquivos para estabelecer um canal de fluxo de dados.
Iniciar uma tarefa de fluxo de dados: Chame a operação CreateDataFlowTask para criar e iniciar uma tarefa de fluxo de dados. O status da tarefa deve ser Running.
Consultar a lista de subtarefas: As subtarefas são geradas automaticamente durante a execução de uma tarefa de fluxo de dados. Chame a operação DescribeDataFlowSubTasks para consultar a lista dessas subtarefas.

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:DescribeDataFlowSubTasks

list

*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. Apenas os sistemas de arquivos CPFS for Lingjun são suportados. O ID deve começar com `bmcpfs-`.	bmcpfs-370lx1ev9ss27o0****
Filters	array<object>	Não	As chaves de filtro usadas para consultar as tarefas de streaming de um fluxo de dados.
	object	Não
Key	string	Não	O nome da chave de filtro. Valores válidos: DataFlowIds: filtra por ID do fluxo de dados. DataFlowTaskIds: filtra por ID da tarefa de fluxo de dados. DataFlowSubTaskIds: filtra por ID da tarefa de streaming do fluxo de dados. Status: filtra por status do fluxo de dados. SrcFilePath: filtra por caminho do arquivo de origem. DstFilePath: filtra por caminho do arquivo de destino. Valores válidos: Status : Filtra por status do fluxo de dados. DstFilePath : Filtra por caminho do arquivo de destino. DataFlowSubTaskIds : Filtra por ID da tarefa de streaming do fluxo de dados. SrcFilePath : Filtra por caminho do arquivo de origem. DataFlowIds : Filtra por ID do fluxo de dados. DataFlowTaskIds : Filtra por ID da tarefa de fluxo de dados.	DataFlowSubTaskIds
Value	string	Não	O valor da chave de filtro. Este parâmetro não suporta curingas. Se Key estiver definido como DataFlowIds, Value será definido como um ID de fluxo de dados ou parte de um ID de fluxo de dados. Você pode especificar um ou mais IDs de fluxo de dados. Um máximo de 10 IDs de fluxo de dados pode ser especificado. Exemplo: `df-194433a5be31**` ou `df-194433a512a2,df-234533a5be31`. Se Key estiver definido como DataFlowTaskIds, Value será definido como um ID de tarefa de fluxo de dados ou parte de um ID de tarefa de fluxo de dados. Você pode especificar um ou mais IDs de tarefa de fluxo de dados. Um máximo de 10 IDs de tarefa de fluxo de dados pode ser especificado. Exemplo: `task-29ee8e890f45` ou `task-29ee8e890f45,task-38ae8e890f45`. Se Key estiver definido como DataFlowSubTaskIds, Value será definido como um ID de tarefa de streaming de fluxo de dados ou parte de um ID de tarefa de streaming de fluxo de dados. Você pode especificar um ou mais IDs de tarefa de streaming de fluxo de dados. Um máximo de 10 IDs de tarefa de streaming de fluxo de dados pode ser especificado. Exemplo: `subTaskId-370kyfmyknxcyzw` ou `subTaskId-247kyfmyknxcyzw,subTaskId-256kyfmyknxcyzw**`. Se Key estiver definido como Status, Value será definido como o status da tarefa de fluxo de dados. Valores válidos: EXPIRED, CREATED, RUNNING, COMPLETE, CANCELING, FAILED e CANCELED. Consultas combinadas são suportadas. Se Key estiver definido como SrcFilePath, Value será definido como o caminho do arquivo de origem. O caminho pode ter até 1.023 caracteres de comprimento. Se Key estiver definido como DstFilePath, Value será definido como o caminho do arquivo de destino. O caminho pode ter até 1.023 caracteres de comprimento.	subTaskId-370kyfmyknxcyzw****
NextToken	string	Não	O token usado para recuperar a próxima página de resultados quando os resultados retornados são truncados. Você pode usar NextToken para iniciar outra solicitação e recuperar os resultados após o ponto de truncamento atual.	iWk0AQAAAAAvY2FzZS8=
MaxResults	integer	Não	O número máximo de entradas a serem retornadas para uma única solicitação. Valores válidos: 20 a 100. Valor padrão: 20.	20

Elementos de resposta

Elemento	Tipo	Descrição	Exemplo
	object
RequestId	string	O ID da solicitação.	98696EF0-1607-4E9D-B01D-F20930B6****
NextToken	string	O token usado para recuperar a próxima página de resultados quando os resultados retornados são truncados. Você pode usar NextToken para iniciar outra solicitação e recuperar os resultados após o ponto de truncamento atual.	pUJaUwAAAABhdGUyNTk1MQ==
DataFlowSubTask	object
DataFlowSubTask	array<object>	A coleção de informações da tarefa de streaming do fluxo de dados.
	array<object>
FileSystemId	string	O ID do sistema de arquivos.	bmcpfs-370lx1ev9ss27o0****
DataFlowId	string	O ID do fluxo de dados.	df-194433a5be31****
DataFlowTaskId	string	O ID da tarefa de fluxo de dados.	task-38aa8e890f45****
DataFlowSubTaskId	string	O ID da tarefa de streaming do fluxo de dados.	subTaskId-370kyfmyknxcyzw****
SrcFilePath	string	O caminho do arquivo de origem. Limites: O caminho deve ter de 1 a 1.023 caracteres de comprimento. O caminho deve ser codificado em UTF-8. O caminho deve começar com uma barra (/). O caminho deve terminar com um nome de arquivo.	/test/file.png
DstFilePath	string	O caminho do arquivo de destino. Limites: O caminho deve ter de 1 a 1.023 caracteres de comprimento. O caminho deve ser codificado em UTF-8. O caminho deve começar com uma barra (/). O caminho deve terminar com um nome de arquivo.	/mnt/file.png
Status	string	O status atual da tarefa de streaming do fluxo de dados. Valores válidos: EXPIRED: A tarefa foi encerrada. CREATED: A tarefa foi criada. RUNNING: A tarefa está em execução. COMPLETE: A tarefa foi concluída. CANCELING: A tarefa está sendo cancelada. FAILED: A tarefa falhou. CANCELED: A tarefa foi cancelada.	FAILED
Progress	integer	O progresso de execução da tarefa de streaming do fluxo de dados. Valores válidos: 0 a 10000.	10000
CreateTime	string	A hora em que a tarefa de streaming foi criada. A hora segue o padrão ISO 8601 no formato yyyy-MM-dd HH:mm:ss.	2024-07-01 19:59:29
StartTime	string	A hora em que a tarefa de streaming começou a ser executada. A hora segue o padrão ISO 8601 no formato yyyy-MM-dd HH:mm:ss.	2024-07-03 10:43:16
EndTime	string	A hora em que a tarefa de streaming terminou. A hora segue o padrão ISO 8601 no formato yyyy-MM-dd HH:mm:ss.	2024-07-04 11:14:22
ErrorMsg	string	A mensagem de erro retornada quando a tarefa falha. Nota Se este campo não for retornado ou estiver vazio, nenhuma mensagem de erro estará disponível.	file does not exist
ProgressStats	object	As estatísticas de progresso da tarefa de streaming do fluxo de dados.
BytesTotal	integer	A quantidade de dados verificada na origem. Unidade: bytes.	68
BytesDone	integer	A quantidade de dados para a qual o fluxo de dados foi concluído, incluindo dados ignorados. Unidade: bytes.	68
ActualBytes	integer	A quantidade real de dados transferidos. Unidade: bytes.	68
AverageSpeed	integer	A velocidade média de transferência de dados. Unidade: bytes/s.	34
FileDetail	object	Os detalhes do arquivo.
ModifyTime	integer	A hora em que o arquivo foi modificado pela última vez. O valor é um timestamp UNIX em nanossegundos.	1725897600000000000
Size	integer	O tamanho do arquivo. Unidade: bytes.	68
Checksum	string	A soma de verificação do arquivo. Formato de exemplo: crc64:123456.	crc64:850309505450944****

Exemplos

Resposta de sucesso

JSON formato

{
  "RequestId": "98696EF0-1607-4E9D-B01D-F20930B6****",
  "NextToken": "pUJaUwAAAABhdGUyNTk1MQ==",
  "DataFlowSubTask": {
    "DataFlowSubTask": [
      {
        "FileSystemId": "bmcpfs-370lx1ev9ss27o0****\n",
        "DataFlowId": "df-194433a5be31****\n",
        "DataFlowTaskId": "task-38aa8e890f45****",
        "DataFlowSubTaskId": "subTaskId-370kyfmyknxcyzw****\n",
        "SrcFilePath": "/test/file.png\n",
        "DstFilePath": "/mnt/file.png\n",
        "Status": "FAILED",
        "Progress": 10000,
        "CreateTime": "2024-07-01 19:59:29",
        "StartTime": "2024-07-03 10:43:16",
        "EndTime": "2024-07-04 11:14:22",
        "ErrorMsg": "file does not exist",
        "ProgressStats": {
          "BytesTotal": 68,
          "BytesDone": 68,
          "ActualBytes": 68,
          "AverageSpeed": 34
        },
        "FileDetail": {
          "ModifyTime": 1725897600000000000,
          "Size": 68,
          "Checksum": "crc64:850309505450944****"
        }
      }
    ]
  }
}

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	InvalidFilesystemVersion.NotSupport	This Api does not support this fileSystem version.	A operação atual não oferece suporte a esta versão do sistema de arquivos.
403	OperationDenied.DataFlowNotSupported	The operation is not supported.	O sistema de arquivos não suporta dataflow.
404	InvalidParameter.InvalidNextToken	The specified NextToken is invaild.
404	InvalidFileSystem.NotFound	The specified file system does not exist.	O sistema de arquivos especificado não existe.
404	InvalidDataFlow.NotFound	The specified data flow does not exist.	O fluxo de dados especificado não existe.
404	InvalidParameter.InvalidMaxResults	The specified MaxResults is invalid.	O valor de MaxResults especificado é inválido.
404	InvalidFilterParam	The specified Filter.N.Key is invalid.	O parâmetro Filter.N.Key especificado é inválido.

Consulte Códigos de Erro para uma lista completa.

Notas de versão

Consulte Notas de Versão para uma lista completa.