Toda vez que uma integração ETL é executada, ela passa por três fases:

Extract — obtém os dados da fonte (por exemplo, seu ERP ou banco de dados).
Transform — limpa e adapta os dados para que fiquem no formato correto.
Load — carrega os dados já processados no destino final (por exemplo, a Fracttal).

O que você precisa para usá-lo?

Antes de fazer a consulta, você precisa ter em mãos:

Dado	Onde obter	Exemplo
`dag_id`	Endpoint Listar DAGs	`589b6c65-1ce9-4a46-9c11-ad380d9bf27a`
`date`	Data da execução que você quer revisar	`2026-06-05`
`run_id`	Identificador da execução (visível no histórico de runs)	`manual_20260605T140709_c003`
`phase`	A fase que você quer revisar: `extract`, `transform` ou `load`	`load`

Importante: Se o run_id contiver os caracteres : ou +, você deve codificá-los na URL antes de enviar (substitua : por %3A e + por %2B).

Filtros opcionais

Parâmetro	Função	Padrão
`attempt`	Seleciona qual tentativa ver (1 = mais recente)	`1`
`page`	Navegação entre páginas de resultados	`0`
`limit`	Registros por página	`50`
`keyword`	Busca de texto dentro dos registros	—

Autenticação

Você precisa de um token de acesso OAuth2. Ver Autenticação.

Authorization: Bearer <seu_token>

Exemplo de consulta

Buscar registros da fase load do dia 5 de junho que contenham a palavra "error":

GET /hub/api/v1/dags/589b6c65-1ce9-4a46-9c11-ad380d9bf27a/runs/2026-06-05/manual_20260605T140709_c003/phases/load/data?page=0&limit=50&keyword=error
Authorization: Bearer eyJhbGciOiJSUzI1NiIsInR5cCI6IkpXVCJ9...

O que ele retorna?

{
  "rows": [
    { "campo_1": "valor_a", "campo_2": 9486 },
    { "campo_1": "valor_b", "campo_2": 3314.15 }
  ],
  "total": 4668,
  "page": 0,
  "limit": 50,
  "has_more": true,
  "not_found": false,
  "message": null
}

Campo	Descrição
`rows`	Os registros da página atual. Os nomes das colunas dependem de cada integração.
`total`	Total de registros que correspondem à sua busca.
`page`	Número da página que você está vendo (começa em 0).
`limit`	Quantos registros são exibidos por página.
`has_more`	`true` se houver mais páginas disponíveis, `false` se você já chegou ao final.
`not_found`	`true` se a fase não gerou dados (por exemplo, se falhou antes de produzir resultados).
`message`	Mensagem adicional do sistema, se aplicável.

Como navegar entre páginas

Os resultados são entregues em blocos. Se has_more for true, há mais registros na página seguinte:

page=0 → registros 1–50
page=1 → registros 51–100
page=2 → registros 101–150

Continue aumentando page até que has_more seja false ou rows venha vazio.

Possíveis problemas

O token é inválido ou expirou (`401`)

Obtenha um novo token antes de tentar novamente. Ver Autenticação.

Algum parâmetro tem um valor incorreto (`422`)

A resposta inclui um array details[] que indica exatamente qual campo tem o problema:

{
  "error_code": "VALIDATION_ERROR",
  "message": "Invalid request parameters",
  "status_code": 422,
  "details": [
    { "field": "phase", "message": "phase must be one of: extract, transform, load" }
  ]
}

Causas frequentes:

Campo	Problema habitual
`dag_id`	Formato incorreto (deve estar no formato `8-4-4-4-12`)
`date`	Formato diferente de `YYYY-MM-DD` (ex.: `05-06-2026` não é válido)
`phase`	Valor não reconhecido — só são aceitos `extract`, `transform` ou `load`
`run_id`	Contém `:` ou `+` sem codificar

A fase não tem dados (`not_found: true`)

Isso não é um erro, mas sim uma resposta normal que indica que a fase não produziu registros. Ocorre quando:

A fase anterior falhou e esta não chegou a ser executada (ex.: se extract falhou, transform não tem dados).
A execução foi cancelada antes que a fase terminasse.
O número de attempt solicitado não existe para essa execução.

OpenAPI definition

{
  "openapi": "3.0.0",
  "info": {
    "version": "1.0.0",
    "title": "Consultar registros por fase de uma execução"
  },
  "servers": [
    {
      "url": " https://one.fracttal.com/hub/api/v1/dags/{dag_id}/runs/{date}/{run_id}/phases/{phase}/data"
    }
  ],
  "paths": {
    "/new-endpoint-1": {
      "get": {
        "operationId": "",
        "responses": {
          "200": {
            "description": ""
          }
        },
        "parameters": [],
        "description": "Este endpoint permite ver, linha por linha, quais registros uma fase específica processou durante uma execução. Você também pode buscar registros específicos usando palavras-chave.",
        "summary": "Consultar registros processados por fase"
      }
    }
  },
  "x-readme": {
    "explorer-enabled": true,
    "proxy-enabled": true
  }
}