Todos os produtos
Search
Central de documentação

Cloud Parallel File Storage:DescribeDataFlowTasks

Última atualização: Jul 31, 2026

Consulta os detalhes das tarefas de fluxo de dados.

Descrição da operação

Somente o CPFS 2.2.0 e versões posteriores e o CPFS for Lingjun 2.4.0 e versões posteriores suportam a consulta de tarefas de fluxo de dados. Você pode visualizar as informações da versão na página de detalhes do sistema de arquivos no console.

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

get

*DataFlow

acs:nas:{#regionId}:{#accountId}:filesystem/{#filesystemId}

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-290w65p03ok64ya****

Filters

array<object>

Não

As condições de filtro.

object

Não

Key

string

Não

O nome da chave de filtro.

Valores válidos:

  • Status :

    filtra pelo status do fluxo de dados.

  • TaskIds :

    filtra por ID de tarefa de fluxo de dados.

  • Originator :

    filtra pelo iniciador da tarefa de fluxo de dados.

  • CreateTimeEnd :

    filtra tarefas de fluxo de dados criadas antes do horário especificado.

  • EndTimeBegin :

    filtra tarefas de fluxo de dados finalizadas após o horário especificado.

  • DataFlowIds :

    filtra por ID de fluxo de dados.

  • StartTimeEnd :

    filtra tarefas de fluxo de dados iniciadas antes do horário especificado.

  • TaskActions :

    filtra pelo tipo da tarefa de fluxo de dados.

  • EndTimeEnd :

    filtra tarefas de fluxo de dados finalizadas antes do horário especificado.

  • StartTimeBegin :

    filtra tarefas de fluxo de dados iniciadas após o horário especificado.

  • CreateTimeBegin :

    filtra tarefas de fluxo de dados criadas após o horário especificado.

  • DataTypes :

    filtra pelo tipo de dados da tarefa de fluxo de dados.

DataFlowIds

Value

string

Não

O valor da chave de filtro. Caracteres curinga não são suportados.

df-194433a5be31****

NextToken

string

Não

O token de paginação usado na próxima solicitação para recuperar uma nova página de resultados. Se os resultados retornados forem truncados, você pode usar NextToken para iniciar uma nova solicitação e recuperar o conteúdo após o ponto de truncamento.

TGlzdFJlc291cmNlU****mVzJjE1MTI2NjY4NzY5MTAzOTEmMiZORnI4NDhVeEtrUT0=

MaxResults

integer

Não

O número de resultados para cada consulta.

20

WithReports

boolean

Não

Especifica se as informações do relatório devem ser consultadas.

True

Elementos de resposta

Elemento

Tipo

Descrição

Exemplo

object

RequestId

string

O ID da solicitação.

2D69A58F-345C-4FDE-88E4-BF518948****

NextToken

string

O token de paginação usado na próxima solicitação para recuperar uma nova página de resultados. Se os resultados retornados forem truncados, você pode usar NextToken para iniciar uma nova solicitação e recuperar o conteúdo após o ponto de truncamento.

TGlzdFJlc291cmNlU****mVzJjE1MTI2NjY4NzY5MTAzOTEmMiZORnI4NDhVeEtrUT0=

TaskInfo

object

Task

array<object>

A coleção de informações da tarefa de fluxo de dados.

array<object>

FilesystemId

string

O ID do sistema de arquivos.

bmcpfs-290w65p03ok64ya****

DataFlowId

string

O ID do fluxo de dados.

df-194433a5be31****

TaskId

string

O ID da tarefa de fluxo de dados.

task-38aa8e890f45****

SourceStorage

string

O endereço de acesso do armazenamento de origem. Formato: <tipo de armazenamento>://[<ID da conta>:]<caminho>.

oss://178321033379****:bucket-01

FileSystemPath

string

O caminho do fileset no sistema de arquivos CPFS.

/a/b/c/

Originator

string

O iniciador da tarefa de fluxo de dados. Valores válidos:

User

TaskAction

string

O tipo do nó de fluxo de dados. Valores válidos:

Import

DataType

string

O tipo de dados da tarefa de fluxo de dados. Valores válidos:

MetaAndData

Progress

integer

O progresso da tarefa de fluxo de dados. O número de operações que foram executadas pela tarefa de fluxo de dados atual.

50

Status

string

O status da tarefa de fluxo de dados. Valores válidos:

Failed

ReportPath deprecated

string

O caminho onde o relatório da tarefa de fluxo de dados é armazenado no sistema de arquivos CPFS.

/path_in_cpfs/reportfile.cvs

CreateTime

string

A hora em que a tarefa foi criada. A hora segue o padrão ISO 8601. Formato: yyyy-MM-dd HH:mm:ss.

2021-08-04 18:27:35

StartTime

string

A hora em que a tarefa começou. A hora segue o padrão ISO 8601. Formato: yyyy-MM-dd HH:mm:ss.

2021-08-04 18:27:35

EndTime

string

A hora em que a tarefa terminou. A hora segue o padrão ISO 8601. Formato: yyyy-MM-dd HH:mm:ss.

2021-08-04 18:27:35

FsPath

string

O caminho do diretório inteligente.

/aa/

ConflictPolicy

string

A política de conflito de nomes de arquivo.

Valores válidos:

  • KEEP_LATEST :

    Compara a hora de atualização e mantém a versão mais recente.

  • OVERWRITE_EXISTING :

    Substitui forçadamente arquivos com o mesmo nome.

  • SKIP_THE_FILE :

    Ignora arquivos com o mesmo nome.

KEEP_LATEST

Directory

string

O diretório no qual a tarefa de fluxo de dados é executada.

/path_in_cpfs/

DstDirectory

string

O diretório de destino para o qual a tarefa de fluxo de dados é mapeada.

/path_in_cpfs/

ErrorMsg

string

A mensagem de erro da tarefa.

{"ErrorKey":"PATH_NOT_ACCESSIBLE","ErrorDetail":"lstat /cpfs/370lx1ev9ss27o****/test/abcdfnotfound: no such file or directory"}

ProgressStats

object

As informações de progresso da tarefa de fluxo de dados.

FilesTotal

integer

O número total de arquivos verificados na origem.

3

FilesDone

integer

O número de arquivos para os quais o fluxo de dados foi concluído (incluindo arquivos ignorados).

3

ActualFiles

integer

O número real de arquivos transferidos.

3

BytesTotal

integer

A quantidade total de dados verificados na origem. Unidade: bytes.

131092971520

BytesDone

integer

A quantidade de dados para os quais o fluxo de dados foi concluído (incluindo dados ignorados). Unidade: bytes.

131092971520

ActualBytes

integer

A quantidade real de dados transferidos. Unidade: bytes.

131092971520

RemainTime

integer

O tempo restante estimado. Unidade: segundos.

437

AverageSpeed

integer

A velocidade média de transferência. Unidade: bytes por segundo.

342279299

Reports

object

Report

array<object>

A lista de relatórios.

object

Name

string

O nome do relatório.

TotalFilesReport

Path

string

O link do relatório.

https://a-hbr-temp-cn-hangzhou-staging.oss-cn-hangzhou.aliyuncs.com/temp/report/162319438359****/job-000bb6fwqficjbxk****/job-000bb6fwqficjbxk****_failed.zip?Expires=1721201422&OSSAccessKeyId=LTA****************&Signature=Fp%2BvauORTIVxooXY2tec6z0T%2Bp4%3D

Includes

string

Filtra diretórios sob o diretório especificado e transfere o conteúdo das pastas filtradas.

["/test/","/test1/"]

TransferFileListPath

string

Especifica um diretório do OSS e sincroniza dados com base no conteúdo de arquivos CSV no diretório do OSS.

/path_in_cpfs/

EntryList

string

A lista de arquivos nos quais a tarefa de fluxo de dados é executada.

["/path_in_cpfs/file1", "/path_in_cpfs/file2"]

Exemplos

Resposta de sucesso

JSON formato

{
  "RequestId": "2D69A58F-345C-4FDE-88E4-BF518948****",
  "NextToken": "TGlzdFJlc291cmNlU****mVzJjE1MTI2NjY4NzY5MTAzOTEmMiZORnI4NDhVeEtrUT0=",
  "TaskInfo": {
    "Task": [
      {
        "FilesystemId": "bmcpfs-290w65p03ok64ya****",
        "DataFlowId": "df-194433a5be31****",
        "TaskId": "task-38aa8e890f45****",
        "SourceStorage": "oss://178321033379****:bucket-01",
        "FileSystemPath": "/a/b/c/",
        "Originator": "User",
        "TaskAction": "Import",
        "DataType": "MetaAndData",
        "Progress": 50,
        "Status": "Failed",
        "ReportPath": "/path_in_cpfs/reportfile.cvs",
        "CreateTime": "2021-08-04 18:27:35",
        "StartTime": "2021-08-04 18:27:35",
        "EndTime": "2021-08-04 18:27:35",
        "FsPath": "/aa/",
        "ConflictPolicy": "KEEP_LATEST",
        "Directory": "/path_in_cpfs/",
        "DstDirectory": "/path_in_cpfs/",
        "ErrorMsg": "{\"ErrorKey\":\"PATH_NOT_ACCESSIBLE\",\"ErrorDetail\":\"lstat /cpfs/370lx1ev9ss27o****/test/abcdfnotfound: no such file or directory\"}",
        "ProgressStats": {
          "FilesTotal": 3,
          "FilesDone": 3,
          "ActualFiles": 3,
          "BytesTotal": 131092971520,
          "BytesDone": 131092971520,
          "ActualBytes": 131092971520,
          "RemainTime": 437,
          "AverageSpeed": 342279299
        },
        "Reports": {
          "Report": [
            {
              "Name": "TotalFilesReport",
              "Path": "https://a-hbr-temp-cn-hangzhou-staging.oss-cn-hangzhou.aliyuncs.com/temp/report/162319438359****/job-000bb6fwqficjbxk****/job-000bb6fwqficjbxk****_failed.zip?Expires=1721201422&OSSAccessKeyId=LTA****************&Signature=Fp%2BvauORTIVxooXY2tec6z0T%2Bp4%3D"
            }
          ]
        },
        "Includes": "[\"/test/\",\"/test1/\"]",
        "TransferFileListPath": "/path_in_cpfs/",
        "EntryList": "[\"/path_in_cpfs/file1\", \"/path_in_cpfs/file2\"]"
      }
    ]
  }
}

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 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.DataFlowNotSupported The operation is not supported. O sistema de arquivos não suporta fluxos de dados.
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 dataflow especificado não existe.
404 InvalidParameter.InvalidMaxResults The specified MaxResults is invalid. O 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.