Version: 2.0.0

Db2CdcStreamSrcConn

class

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

Bases: Conn

Categories: source

Db2 CDC connection used by Db2CdcStreamSrc.

Mirrors Db2SrcConn for the SQLAlchemy / catalog introspection side. SQL Replication needs no distinct replica identifier on the connection: the CD tables and the ASN.IBMSNAP_* capture tables live in the same database as the source, so an authenticated role with SELECT on the CD tables and ASN.IBMSNAP_REGISTER suffices. Not a subclass of Db2SrcConn -- CDC and batch SQL have different operational guarantees (the capture schema must be in place, the connecting role typically needs different grants).

Parameters

parameter

uriUriSpec (str | Secret)

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

parameter

credentialsCredentialsSpec (UserPassword)

UserPassword credentials.

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