pg_accumulator
PostgreSQL 中用于余额与周转跟踪的累积寄存器
仓库
Treedo/pg_accumulator
https://github.com/Treedo/pg_accumulator
源码
pg_accumulator-1.1.3.tar.gz
pg_accumulator-1.1.3.tar.gz
概览
| 扩展包名 | 版本 | 分类 | 许可证 | 语言 |
|---|---|---|---|---|
pg_accumulator | 1.1.3 | FUNC | PostgreSQL | C |
| ID | 扩展名 | Bin | Lib | Load | Create | Trust | Reloc | 模式 |
|---|---|---|---|---|---|---|---|---|
| 4845 | pg_accumulator | 否 | 是 | 否 | 是 | 否 | 否 | accum |
| 相关扩展 | plpgsql financial topn quantile first_last_agg |
|---|
版本
| 类型 | 仓库 | 版本 | PG 大版本 | 包名 | 依赖 |
|---|---|---|---|---|---|
| EXT | PIGSTY | 1.1.3 | 1817161514 | pg_accumulator | plpgsql |
| RPM | PIGSTY | 1.1.3 | 1817161514 | pg_accumulator_$v | - |
| DEB | PIGSTY | 1.1.3 | 1817161514 | postgresql-$v-pg-accumulator | - |
构建
您可以使用 pig build 命令构建 pg_accumulator 扩展的 RPM / DEB 包：
pig build pkg pg_accumulator # 构建 RPM / DEB 包
安装
您可以直接安装 pg_accumulator 扩展包的预置二进制包，首先确保 PGDG 和 PIGSTY 仓库已经添加并启用：
pig repo add pgsql -u # 添加仓库并更新缓存
使用 pig 或者是 apt/yum/dnf 安装扩展：
pig install pg_accumulator; # 当前活跃 PG 版本安装
pig ext install -y pg_accumulator -v 18 # PG 18
pig ext install -y pg_accumulator -v 17 # PG 17
pig ext install -y pg_accumulator -v 16 # PG 16
pig ext install -y pg_accumulator -v 15 # PG 15
pig ext install -y pg_accumulator -v 14 # PG 14
dnf install -y pg_accumulator_18 # PG 18
dnf install -y pg_accumulator_17 # PG 17
dnf install -y pg_accumulator_16 # PG 16
dnf install -y pg_accumulator_15 # PG 15
dnf install -y pg_accumulator_14 # PG 14
apt install -y postgresql-18-pg-accumulator # PG 18
apt install -y postgresql-17-pg-accumulator # PG 17
apt install -y postgresql-16-pg-accumulator # PG 16
apt install -y postgresql-15-pg-accumulator # PG 15
apt install -y postgresql-14-pg-accumulator # PG 14
创建扩展：
CREATE EXTENSION pg_accumulator CASCADE; -- 依赖: plpgsql
用法
来源：README，documentation，control file
pg_accumulator 为 PostgreSQL 提供声明式累积寄存器。寄存器按任意维度和资源记录业务流水，并生成余额、发生额、流水历史、校验和重建等查询与维护函数。
启用
CREATE EXTENSION pg_accumulator;
如果高写入场景需要 delta buffer 和后台 worker，需要预加载共享库并重启 PostgreSQL：
shared_preload_libraries = 'pg_accumulator'
创建寄存器
SELECT accum.register_create(
name := 'inventory',
dimensions := '{"warehouse": "int", "product": "int"}',
resources := '{"quantity": "numeric", "amount": "numeric"}',
kind := 'balance'
);
一次调用会创建寄存器元数据、流水表、汇总表、余额缓存、触发器、生成查询函数和配套索引。
记账与查询
SELECT accum.register_post('inventory', '{
"period": "2026-04-01",
"document": "receipt:1",
"dimensions": {"warehouse": 1, "product": 42},
"resources": {"quantity": 10, "amount": 250}
}');
SELECT * FROM accum.inventory_balance(
dimensions := '{"warehouse": 1, "product": 42}'
);
SELECT * FROM accum.inventory_turnover(
from_date := '2026-04-01',
to_date := '2026-04-30',
dimensions := '{"warehouse": 1}',
group_by := '["product"]'
);
更正与维护
使用 register_unpost 和 register_repost 处理追溯更正。必要时使用 register_verify、register_rebuild_totals、register_rebuild_cache 校验和修复派生状态。
SELECT accum.register_unpost('inventory', 'receipt:1');
SELECT accum.register_verify('inventory');
配置
文档中的 GUC 包括 pg_accumulator.background_workers、pg_accumulator.delta_merge_interval、pg_accumulator.delta_merge_delay、pg_accumulator.delta_merge_batch_size、pg_accumulator.partitions_ahead、pg_accumulator.maintenance_interval。