pg_squeeze（表空间整理）

步骤一：配置集群参数

1. 登录PolarDB控制台，在集群列表页面找到目标集群，单击集群ID进入详情页。

2. 在左侧导航栏选择配置与管理 > 参数配置。

3. 在参数配置页面，修改以下参数：

   • wal_level：设置为logical。这是使用逻辑解码功能的前提，会适度增加WAL日志的生成量。

   • max_replication_slots：确保有足够余量。pg_squeeze在每个启用的数据库中至少需要1 + squeeze.workers_per_database个复制槽。建议设置为比当前值至少大2的值（例如，从10调整到12）。

   • shared_preload_libraries：在现有值的基础上追加,pg_squeeze。例如，如果原值为pg_stat_statements，则修改为pg_stat_statements,pg_squeeze。

4. 等待集群重启后参数配置生效。

步骤二：安装插件并启动后台进程

在需要进行表空间整理的目标数据库中启用pg_squeeze功能。

1. 登录至目标数据库。

2. 执行以下SQL语句，创建插件并启动后台调度工作进程（Scheduler Worker）。该进程会根据squeeze.tables中的配置，定时检查并创建压缩任务。

   -- 在目标数据库中创建扩展
   CREATE EXTENSION pg_squeeze;
   
   -- 启动后台调度进程
   -- 此操作只需在每个需要使用pg_squeeze的数据库中执行一次
   SELECT squeeze.start_worker();

3. （可选）执行以下SQL语句，验证后台进程是否成功启动。如果看到application_name为squeeze scheduler的进程，则表示启动成功。

   SELECT * FROM pg_stat_activity WHERE application_name LIKE 'squeeze%';

步骤三：配置待处理的表

告知pg_squeeze需要管理哪些表，以及按何种策略进行检查和压缩。

1. 确保表具备REPLICA IDENTITY（副本标识）：pg_squeeze需要通过唯一标识来匹配新旧表中的行变更。通常，主键（Primary Key）会自动作为REPLICA IDENTITY。

   • 检查：使用\d+ your_table_name命令查看表的Replica identity属性是否为DEFAULT或FULL。

   • 设置：如果表没有主键，但有一个唯一索引（例如your_table_uidx），可执行以下命令将其设置为REPLICA IDENTITY。

     ALTER TABLE your_table_name REPLICA IDENTITY USING INDEX your_table_uidx;

2. 将表注册到squeeze.tables：将表信息及调度策略插入squeeze.tables配置表中。schedule字段用于定义检查时间，其格式类似于Cron表达式。

   -- 示例1：每天凌晨2:30检查public.foo表
   INSERT INTO squeeze.tables (tabschema, tabname, schedule)
   VALUES ('public', 'foo', ROW(ARRAY[30], ARRAY[2], NULL, NULL, NULL)::squeeze.schedule);
   
   -- 示例2：每周日凌晨4:00检查public.bar表，并指定压缩后按主键排序
   INSERT INTO squeeze.tables (tabschema, tabname, schedule, clustering_index)
   VALUES ('public', 'bar', ROW(ARRAY[0], ARRAY[4], NULL, NULL, ARRAY[0])::squeeze.schedule, 'bar_pkey');

   schedule字段的结构为(分钟, 小时, 日, 月, 星期)。NULL表示任意时间。更多配置请参见附录：squeeze.tables配置表详解。

步骤四：监控与验证

确认压缩任务是否按预期执行、成功或失败。您可以通过查询pg_squeeze提供的视图和表来监控任务状态。

-- 查看当前数据库中正在进行的压缩任务
SELECT * FROM squeeze.get_active_workers();

-- 查看最近10条成功的压缩历史记录
SELECT * FROM squeeze.log ORDER BY finished DESC LIMIT 10;

-- 查看失败的压缩记录及原因
SELECT * FROM squeeze.errors;

步骤五：（可选）取消定制压缩

如果特定表不再需要定期压缩，只需从squeeze.tables表中删除相应的行即可。

DELETE FROM squeeze.tables WHERE tabschema = 'public' AND tabname = 'foo';

调整并发与锁行为

在不影响业务的前提下，更精细地控制压缩过程。通过设置squeeze.max_xlock_time参数，可以限制压缩最后阶段排他锁的最长持有时间，避免长时间阻塞业务。

-- 设置排他锁最长持有时间为100毫秒
SET squeeze.max_xlock_time TO 100;

如果锁持有时间超过此限制，pg_squeeze会释放锁，处理在此期间发生的数据变更，然后再次尝试获取锁。若多次尝试均超时，任务将报错中止。如果频繁发生锁超时失败，应优先考虑将任务调度到业务负载更低的时间窗口，其次再考虑适当增大此参数值。

配置并发工作进程数

当需要同时处理的表较多时，通过增加工作进程数来提高压缩效率。您可以将squeeze.workers_per_database参数设置为大于1的值，以允许在单个数据库中并行处理多个表的压缩任务。

-- 允许每个数据库最多同时运行2个压缩工作进程
SET squeeze.workers_per_database = 2;