Version: 2.2.0

MySQLCdcStreamSrcConn

class

class MySQLCdcStreamSrcConn(
    uri: UriSpec,
    credentials: CredentialsSpec,
    server_id: int = DEFAULT_SERVER_ID,
    entity_whitelist: EntityWhitelistSpec | None = None,
    conn_cfg: CfgSpec | None = None,
)

Bases: Conn

Categories: source

MySQL CDC connection used by MySQLCdcStreamSrc.

Mirrors MySQLSrcConn for the SQLAlchemy / catalog introspection side and adds server_id -- the unique replica identifier the source uses for binlog replication. Each concurrent CDC connection against the same MySQL must declare a distinct server_id; collisions cause the source to disconnect one of the replicas. Not a subclass of MySQLSrcConn -- CDC and batch SQL have different operational guarantees (replication grants vs query permissions, replica-id reservation).

Parameters

parameter

uriUriSpec (str | Secret)

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

parameter

credentialsCredentialsSpec (UserPassword)

UserPassword credentials.

parameter

server_idint

MySQL replica id for the binlog stream. Defaults to DEFAULT_SERVER_ID (512).

parameter

entity_whitelistEntityWhitelistSpec | None (list[str] | None)

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

parameter

conn_cfgCfgSpec | None (dict | None)

Optional pymysql connection keywords (ssl_ca, ssl_cert, ssl_key, ssl_disabled, charset, connect_timeout, ...) every connection the stream opens takes: the catalog engine, the binlog reader, the initial load and the server checks alike. A bare mysql:// URI connects through pymysql here, the stream's driver; an explicit +driver is honoured for the catalog engine.

#

Parameters​

#

#

#

#

#

Parameters