Version: 2.0.0

PostgresCdcStreamSrcConn

class

class PostgresCdcStreamSrcConn(
    uri: UriSpec,
    credentials: CredentialsSpec,
    entity_whitelist: EntityWhitelistSpec | None = None,
    conn_cfg: CfgSpec | None = None,
)

Bases: Conn

Categories: source

Postgres CDC connection used by PostgresCdcStreamSrc.

Mirrors PostgresSrcConn for the SQLAlchemy / catalog introspection side. The replication slot and publication live on PostgresCdcStreamSrc instead, so one connection can front multiple sources if each uses a distinct slot. Not a subclass of PostgresSrcConn -- CDC and batch SQL have different operational guarantees (the connecting role needs the REPLICATION attribute; the slot retention model is separate from query permissions).

Parameters

parameter

uriUriSpec (str | Secret)

SQLAlchemy-style Postgres URI; accepts a plain string or a Secret (see UriSpec).

parameter

credentialsCredentialsSpec (UserPassword)

UserPassword credentials. The connecting role must have the REPLICATION attribute.

parameter

entity_whitelistEntityWhitelistSpec | None (list[str] | None)

Optional regex patterns narrowing discovery; None (default) means no filtering.

parameter

conn_cfgCfgSpec | None (dict | None)

Optional driver-side config forwarded as connect_args.

#

Parameters​

#

#

#

#

Parameters