跳转到主要内容
设置示例:
SOURCE(POSTGRESQL(
    port 5432
    host 'postgresql-hostname'
    user 'postgres_user'
    password 'postgres_password'
    db 'db_name'
    table 'table_name'
    replica(host 'example01-1' port 5432 priority 1)
    replica(host 'example01-2' port 5432 priority 2)
    where 'id=10'
    invalidate_query 'SQL_QUERY'
    query 'SELECT id, value_1, value_2 FROM db_name.table_name'
))

设置字段:
SettingDescription
hostPostgreSQL 服务器的主机地址。您可以为所有副本统一指定,也可以为每个副本单独指定 (在 <replica> 内) 。
portPostgreSQL 服务器的端口。您可以为所有副本统一指定,也可以为每个副本单独指定 (在 <replica> 内) 。
userPostgreSQL 用户名。您可以为所有副本统一指定,也可以为每个副本单独指定 (在 <replica> 内) 。
passwordPostgreSQL 用户密码。您可以为所有副本统一指定,也可以为每个副本单独指定 (在 <replica> 内) 。
replica副本配置节。可以有多个此类配置节。
replica/hostPostgreSQL 主机地址。
replica/portPostgreSQL 端口。
replica/priority副本优先级。尝试连接时,ClickHouse 会按优先级顺序遍历各副本。数字越小,优先级越高。
db数据库名称。
table表名称。
where筛选条件。其语法与 PostgreSQL 中 WHERE 子句的语法相同。例如,id > 10 AND id < 20。可选。
invalidate_query用于检查字典状态的查询。可选。更多信息请参见使用 LIFETIME 刷新字典数据一节。
background_reconnect如果连接失败,则在后台重新连接到副本。可选。
query自定义查询。可选。
tablewhere 字段不能与 query 字段同时使用。此外,tablequery 两个字段中必须声明其中一个。
最后修改于 2026年6月10日