数据湖探索 DLI-Postgres CDC源表:参数说明

时间:2023-11-10 09:20:50

参数说明

表1 参数说明

参数

是否必选

默认值

数据类型

说明

connector

String

connector类型,需配置为'postgres-cdc'。

hostname

String

Postgres数据库的IP地址或者Hostname。

username

String

Postgres数据库用户名。

password

String

Postgres数据库服务的密码。

database-name

String

数据库名称。

schema-name

String

Postgres Schema名称。

Schema名称支持正则表达式以读取多个Schema的数据,例如test(.)*表示以test开头的所有schema。

table-name

String

Postgres表名。

表名支持正则表达式去读取多个表的数据,例如cdc_order(.)*表示以cdc_order开头的所有表。

port

5432

Integer

Postgres数据库服务的端口号。

decoding.plugin.name

decoderbufs

String

根据Postgres服务上安装的插件确定。支持的插件列表如下:

  • decoderbufs(默认值)
  • wal2json
  • wal2json_rds
  • wal2json_streaming
  • wal2json_rds_streaming
  • pgoutput

debezium.*

String

更细粒度控制Debezium客户端的行为。例如'debezium.snapshot.mode' = 'never',详情请参见配置属性

建议每个表都设置debezium.slot.name参数,以避免出现

“PSQLException: ERROR: replication slot "debezium" is active for PID 974”报错。

pwd_auth_name

String

DLI侧创建的Password类型的跨源认证名称。

使用跨源认证则无需在作业中配置账号和密码。

support.huaweicloud.com/sqlref-flink-dli/dli_08_0388.html