spock
PostgreSQL 多主逻辑复制扩展
概览
| 扩展包名 | 版本 | 分类 | 许可证 | 语言 |
|---|---|---|---|---|
spock | 5.0.10 | ETL | PostgreSQL | C |
| ID | 扩展名 | Bin | Lib | Load | Create | Trust | Reloc | 模式 |
|---|---|---|---|---|---|---|---|---|
| 9570 | spock | 是 | 是 | 是 | 是 | 否 | 否 | spock |
| 相关扩展 | lolor snowflake |
|---|
works on pgedge kernel fork
版本
| 类型 | 仓库 | 版本 | PG 大版本 | 包名 | 依赖 |
|---|---|---|---|---|---|
| EXT | PIGSTY | 5.0.10 | 1817161514 | spock | - |
| RPM | PIGSTY | 18.4 | 1817161514 | pgedge-$v | - |
| DEB | PIGSTY | 18.4 | 1817161514 | pgedge-$v | - |
构建
您可以使用 pig build 命令构建 spock 扩展的 RPM / DEB 包:
pig build pkg spock # 构建 RPM / DEB 包
安装
您可以直接安装 spock 扩展包的预置二进制包,首先确保 PGDG 和 PIGSTY 仓库已经添加并启用:
pig repo add pgsql -u # 添加仓库并更新缓存
使用 pig 或者是 apt/yum/dnf 安装扩展:
pig install spock; # 当前活跃 PG 版本安装
pig ext install -y spock -v 18 # PG 18
pig ext install -y spock -v 17 # PG 17
pig ext install -y spock -v 16 # PG 16
pig ext install -y spock -v 15 # PG 15
dnf install -y pgedge-18 # PG 18
dnf install -y pgedge-17 # PG 17
dnf install -y pgedge-16 # PG 16
dnf install -y pgedge-15 # PG 15
apt install -y pgedge-18 # PG 18
apt install -y pgedge-17 # PG 17
apt install -y pgedge-16 # PG 16
apt install -y pgedge-15 # PG 15
预加载配置:
shared_preload_libraries = 'spock';
创建扩展:
CREATE EXTENSION spock;
用法
来源:
spock 为 PostgreSQL 15 至 18 提供了主动-主动逻辑复制。每个参与的数据库都是一个 Spock 节点;通过在节点之间创建有向订阅,形成一个多主拓扑结构。
配置
在 postgresql.conf 中:
wal_level = 'logical'
max_worker_processes = 10
max_replication_slots = 10
max_wal_senders = 10
shared_preload_libraries = 'spock'
track_commit_timestamp = on
spock.enable_ddl_replication = on
spock.include_ddl_repset = on
启用
CREATE EXTENSION spock;
创建节点
在每个节点上创建节点身份:
-- Node 1
SELECT spock.node_create(
node_name := 'n1',
dsn := 'host=10.0.0.5 port=5432 dbname=mydb'
);
-- Node 2
SELECT spock.node_create(
node_name := 'n2',
dsn := 'host=10.0.0.7 port=5432 dbname=mydb'
);
创建订阅
对于多主模式,每个节点订阅其他所有节点:
-- On n1: subscribe to n2
SELECT spock.sub_create(
subscription_name := 'sub_n1n2',
provider_dsn := 'host=10.0.0.7 port=5432 dbname=mydb'
);
-- On n2: subscribe to n1
SELECT spock.sub_create(
subscription_name := 'sub_n2n1',
provider_dsn := 'host=10.0.0.5 port=5432 dbname=mydb'
);
复制集管理
-- Add table to replication
SELECT spock.repset_add_table('default', 'my_table');
-- Remove table from replication
SELECT spock.repset_remove_table('default', 'my_table');
-- Add all tables in a schema
SELECT spock.repset_add_all_tables('default', '{public}');
关键功能
- 多主(主动-主动)复制
- 自动 DDL 复制
- 使用提交时间戳进行冲突检测和解决
- 行和列过滤
- 支持 PostgreSQL 15、16、17 和 18
- 表必须在所有节点上具有主键且模式匹配
操作与注意事项
- 在创建节点或订阅之前,在每个参与的服务器上安装
spock并将其添加到shared_preload_libraries中。 - 确保各节点上的表定义、数据类型、主键和相关唯一索引一致。即使启用了 DDL 复制,也要协调 DDL 操作。
- 被复制的表需要具有主键或其他可用的副本标识符。临时表和未记录表不是复制目标。
- Spock 是按数据库操作的。对于每个参与的数据库,重复扩展名和拓扑结构设置。
- 主动-主动冲突处理依赖于提交时间戳和策略。在生产使用前,请测试同时插入和更新操作,特别是空值唯一键。
- 上游文档中在 README 中列出了平台/构建要求;请验证每个节点上使用的 PostgreSQL 构建和 Spock 包是兼容的。
版本 5.0.10
5.0.10 是 5.0 系列的一个补丁版本。其发布说明包括修复了包含 NULL 的唯一索引、NULLS NOT DISTINCT 冲突处理、在索引删除后刷新缓存的索引元数据、异常路径内存处理以及用于滚动补丁升级期间使用的数值版本检查。将每个节点升级到兼容的补丁级别,并在滚动更改后验证订阅。