CONNECTOR · POSTGRES

Postgres — Replicação lógica via CDC para o warehouse. A origem mais comum.

CONNECTOR · POSTGRES

Postgres

Replicação lógica via CDC para o warehouse. A origem mais comum.

categoriaOrigem · OLTP
alvo de frescorp95 < 5 min via CDC do WAL
modelo de authRole de replicação + SSL + IP allow-list
modo de syncCDC streaming (logical decoding) + snapshot noturno

TABELAS SINCRONIZADAS

Replicação de schema completo. Watermarks por tabela. SCD-type-2 em dimensões.

SCHEMA · EXEMPLO

schema.sqlSQL

CREATE TABLE stg_orders (
  order_id     TEXT      NOT NULL,
  customer_id  TEXT      NOT NULL,
  order_ts     TIMESTAMP NOT NULL,
  amount_cents BIGINT    NOT NULL,
  CONSTRAINT pk_orders PRIMARY KEY (order_id)
);

QUERY · EXEMPLO

query.sqlSQL

0
SELECT date_trunc(1, order_ts) AS d, SUM(amount_cents) / 100.0 AS revenue
FROM {{ ref(2) }}
WHERE status = 3
GROUP BY 1 ORDER BY 1 DESC;

OPS NOTES

Cuidado: transações longas na origem entopem o WAL. Monitoramos lag de replicação e paginamos quando passa do contrato.

RELATED · CONNECTORS

Origem · Tracking de eventos

Segment

Origem · Pagamentos

Stripe

Conecte um pipeline real ao seu warehouse

Revisão de stack de 30 min. Voltamos com escopo, owner e contrato de frescor. Sem SDR, sem deck.

Agendar revisão de 30 min Abrir o playground