CONNECTOR · POSTGRES

Postgres — Replicación lógica vía CDC al warehouse. La fuente más común que operamos.

CONNECTOR · POSTGRES

Postgres

Replicación lógica vía CDC al warehouse. La fuente más común que operamos.

categoríaOrigen · OLTP
target de frescurap95 < 5 min vía CDC del WAL
modelo de authRole de replicación + SSL + IP allow-list
modo de syncCDC streaming (logical decoding) + snapshot nocturno

TABLAS SINCRONIZADAS

Replicación de schema completo. Watermarks por tabla. SCD-type-2 en dimensiones.

SCHEMA · MUESTRA

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 · MUESTRA

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: transacciones largas en origen tapan el WAL. Monitoreamos lag y paginamos cuando supera el contrato.

RELATED · CONNECTORS

Origen · Tracking de eventos

Segment

Origen · Pagos

Stripe

Conectá un pipeline real a tu warehouse

Revisión de stack de 30 min. Volvemos con scope, owner y contrato de frescura. Sin SDR, sin slide deck.

Agendar revisión de 30 min Abrir el playground