webhook trigger

controle

inicia o pipeline a partir de uma chamada http (POST) externa, expondo o corpo da requisição recebida como uma tabela de trabalho — pronta para ser filtrada, transformada e persistida como qualquer outra fonte.

---

quando usar

• receber eventos em tempo real de um sistema externo (ex: notificação de um saas quando um registro é criado/atualizado)
• integrar com serviços que empurram dados via webhook em vez de expor uma api de consulta
• disparar um pipeline sob demanda a partir de uma automação externa (ex: um botão em outra ferramenta)

---

configuração

campo	tipo	obrigatório	descrição
expose_as	string	não	nome da variável de pipeline que recebe o payload bruto · padrão: payload

ao salvar o pipeline, a plataforma gera automaticamente:

• uma url de webhook única para este pipeline
• um token de segurança que deve ser enviado pelo sistema externo para autenticar a chamada

---

como funciona

1. o sistema externo envia um POST para a url do webhook, com um payload json no corpo
2. a plataforma valida o token e injeta o payload no pipeline
3. o nó materializa o payload como uma tabela — se o payload é um objeto, vira uma linha; se é uma lista de objetos, vira múltiplas linhas
4. o payload também fica disponível como variável de pipeline ({{ pipeline.<expose_as> }}) para uso em nós seguintes (ex: um filtro ou uma query parametrizada)

sistema externo
      ↓ POST + token
webhook trigger
      ↓ payload → tabela de trabalho
[fábrica / quality gate / lakehouse writer]

---

exemplo

{
  "expose_as": "payload"
}

se o sistema externo envia:

{ "evento": "pedido_criado", "pedido_id": 4821, "valor": 199.9 }

o nó produz uma tabela com uma linha e as colunas evento, pedido_id, valor — pronta para os nós seguintes.

teste manual sem payload

ao rodar o pipeline manualmente (sem uma chamada http real), o nó produz uma tabela vazia em vez de falhar — permitindo validar o restante do fluxo mesmo sem um evento externo disponível no momento do teste.

proteja a url do webhook

trate a url e o token gerados como uma credencial: qualquer chamada com o token correto dispara uma execução real do pipeline.