DatriseETL con IA

Conector de origen

Conector de PostgreSQL

Integración de PostgreSQL con bases de datos, warehouses y herramientas de BI

Instancias PostgreSQL autogestionadas. Datrise captura entidades de PostgreSQL como tablas, filas, esquemas, índices, secuencias y slots de replicación, y luego entrega modelos normalizados y tipados para reporting en warehouse, atribución y flujos de IA.

La PostgreSQL Logical Replication (pgoutput) + SQL wire protocol se autentica con username / password, las cargas incrementales usan WAL LSN via a logical replication slot's confirmed_flush_lsn, y el proveedor limita a max_wal_senders (default 10) caps concurrent replication connections per cluster, and max_replication_slots (default 10) caps concurrent logical slots; both are self-hosted config limits, not a vendor-imposed API quota.

De los 6 objetos, 6 se sincronizan con upsert por clave primaria y 0 como flujos append-only, de modo que cada ejecución incremental solo mueve lo que cambió desde la última marca de agua. Cada objeto llega a su propia tabla (por ejemplo `hp_postgres_tables`) con el esquema derivado de la API de PostgreSQL, no de un CSV, en cualquiera de los 43 destinos soportados.

Datrise está en acceso anticipado: elige un destino abajo para ver el pipeline de PostgreSQL y únete a la lista de espera para recibir el conector con onboarding guiado.

Sincronización incrementalMapeo consciente del esquema43 destinos disponibles

Qué datos de PostgreSQL extrae Datrise

Cada objeto llega a su propia tabla tipada. El modo de sync se deriva del objeto: los objetos de historial se anexan, el resto se actualiza con upsert.

ObjetoTabla de destinoModo de sync
tableshp_postgres_tablesUpsert por clave primaria, incremental por updated-at
rowshp_postgres_rowsUpsert por clave primaria, incremental por updated-at
schemashp_postgres_schemasUpsert por clave primaria, incremental por updated-at
indexeshp_postgres_indexesUpsert por clave primaria, incremental por updated-at
sequenceshp_postgres_sequencesUpsert por clave primaria, incremental por updated-at
replication slotshp_postgres_replication_slotsUpsert por clave primaria, incremental por updated-at

API de PostgreSQL: datos de configuración del conector

Verificado contra la documentación del proveedor el 2026-09-02. Los valores desconocidos se dejan en blanco, no se inventan.

APIPostgreSQL Logical Replication (pgoutput) + SQL wire protocol
Autenticaciónusername / password — Standard libpq authentication (typically SCRAM-SHA-256 per pg_hba.conf) over a wire-protocol connection opened with `replication=database` to enter logical-decoding walsender mode.
Paginaciónkeyset — An initial snapshot is pulled via primary-key keyset batches (`WHERE pk > $last ORDER BY pk LIMIT n`); ongoing change capture then streams sequentially by WAL LSN rather than paging rows.
Límite de peticionesmax_wal_senders (default 10) caps concurrent replication connections per cluster, and max_replication_slots (default 10) caps concurrent logical slots; both are self-hosted config limits, not a vendor-imposed API quota
Cursor incrementalWAL LSN via a logical replication slot's confirmed_flush_lsn — The slot's `restart_lsn` marks how much WAL PostgreSQL must retain for that consumer, so a connector that falls behind (or disconnects) causes WAL to accumulate on the source disk rather than being dropped.
WebhooksNo
Exportación masivaSí — COPY TO / pg_dump (full-table bulk unload for initial snapshot)
Detección de borradosSí — Logical replication emits DELETE events for tables with REPLICA IDENTITY DEFAULT (primary key) or FULL; a table with no primary key and default REPLICA IDENTITY falls back to NOTHING and cannot identify which row was deleted at all.

Referencia oficial de la API

Compara esto con todas las demás APIs documentadas

Destinos populares para PostgreSQL

Elige un destino abajo para abrir la página de pipeline lista para usar.

  • A
    Airtable

    Destino de hoja relacional para equipos de operaciones y go-to-market.

    Ver pipeline
  • A
    Amazon Athena

    SQL serverless sobre tablas del data lake en S3.

    Ver pipeline
  • A
    Amazon DynamoDB

    Base key-value y documental serverless en AWS.

    Ver pipeline
  • A
    Amazon QuickSight

    BI serverless en AWS con SPICE y analítica embebida.

    Ver pipeline
  • A
    Amazon Redshift

    Almacén a escala petabyte en AWS con Spectrum.

    Ver pipeline
  • A
    Amazon S3 Data Lake

    Zona de aterrizaje en object storage para parquet y snapshots.

    Ver pipeline
  • A
    Apache Superset

    BI open source para exploración SQL, gráficos y publicación de dashboards.

    Ver pipeline
  • A
    Archivos CSV

    Destino de archivos planos para exportaciones y compartición ligera.

    Ver pipeline
  • A
    Azure Data Lake Storage

    Almacenamiento ADLS Gen2 para cargas analíticas.

    Ver pipeline

Preguntas sobre el conector de PostgreSQL

¿Qué datos de PostgreSQL extrae el conector?
6 objetos: tables, rows, schemas, indexes, sequences y replication slots. Cada uno se carga en su propia tabla con tipos preservados; los objetos con historial (0) se cargan como append-only.
¿La integración de PostgreSQL es incremental?
Sí. Tras la carga inicial completa, cada ejecución lee solo los registros cambiados desde la última marca de agua (updated-at o timestamp del evento) y aplica upsert o append según el objeto.
¿A dónde puedo cargar los datos de PostgreSQL?
A 43 destinos: bases de datos relacionales, warehouses, data lakes, hojas de cálculo y herramientas de BI. Cada par PostgreSQL → destino tiene su propia página con el mapeo de objetos a tablas.

Otras fuentes de

Otras fuentes de la misma categoría, cada una con su propia página de conector.

Acceso anticipado

Lanza tu pipeline de PostgreSQL con onboarding guiado

Únete a la lista de espera para obtener acceso prioritario a integraciones de PostgreSQL con setup guiado, mapeo consciente del esquema y sincronización incremental de nivel producción.