PostgresDest

class

class PostgresDest(
    tables: PostgresTableNamesSpec,
    if_table_exists: IfTableExistsSpec = 'append',
    transactional: bool = True,
    dest_cfg: DestCfgSpec | None = None,
)

Bases: Dest

Categories: destination

Postgres destination for @subscriber -- one target table per slot.

Parameters

parameter

tablesPostgresTableNamesSpec (list[str])

Target table names, qualified or bare (see PostgresTableNameSpec); one input slot per table, in order.

parameter

if_table_existsIfTableExistsSpec (Literal['append', 'replace'])

"append" (default) adds rows; "replace" truncates the table before inserting.

parameter

transactionalbool

When True (default), wrap every table write in one transactional session.

parameter

dest_cfgDestCfgSpec | None (Mapping[Literal['postgres.logging_level', 'tabsdata.sql.write_engine', 'tabsdata.sql.chunk_size'], Any] | None)

Optional config mapping over the allowed keys only (postgres.logging_level, tabsdata.sql.write_engine, tabsdata.sql.chunk_size).