云数据库 PostgreSQL WAL 日志来源分析（tencentdb_wal_stat）

一、概述

tencentdb_wal_stat 是云数据库 PostgreSQL 提供的 WAL 日志来源分析扩展，支持在线按 database、schema、table 三个维度统计 WAL 日志的产生量，帮助你快速定位产生大量 WAL 的对象，及时干预避免磁盘空间告急。

核心价值：

·精准定位：按 database → schema → table 逐层下钻，快速找到 WAL 产生大户。

·在线分析：通过 SQL 直接调用，无需离线解析 WAL 文件。

·多维聚合：同时展示 RMGR 类型（Heap/Btree/Transaction 等）、FPI 统计等详细信息。

·生产安全：只读分析，不影响业务运行。

典型场景：

·SaaS 多租户环境下，某租户突发大量写入导致 WAL 堆积。

·逻辑复制消费端积压，需要找出 WAL 产生量最大的表进行限流。

·日常运维监控 WAL 产生趋势，预防磁盘空间问题。

二、环境要求

四、安装扩展

CREATE EXTENSION IF NOT EXISTS tencentdb_wal_stat;

五、验证安装

输入：

SELECT extname, extversion FROM pg_extension WHERE extname = 'tencentdb_wal_stat';

输出：

七、函数

tencentdb_wal_stat(wal_num integer)RETURNS SETOF record

参数：

注意：说明：

注意：wal_num 越大，分析时间越长。建议在业务低峰期执行大范围分析。

八、输出字段

注意：说明：

注意：WAL 总大小 = wal_bytes + wal_fpi_bytes。FPI 是 checkpoint 后首次修改页面时写入的完整页面副本，通常占 WAL 总量的20%~40%。

十、场景一：磁盘告警，快速定位哪个数据库产生了最多 WAL

输入：

— 按数据库汇总 WAL 产生量（分析最近50个 WAL 文件）SELECT database_name, SUM(wal_records) AS total_records, pg_size_pretty(SUM(wal_bytes + wal_fpi_bytes)::bigint) AS total_size, ROUND(SUM(wal_bytes + wal_fpi_bytes) * 100.0 / SUM(SUM(wal_bytes + wal_fpi_bytes)) OVER (), 1) AS pctFROM tencentdb_wal_stat(50)GROUP BY database_nameORDER BY SUM(wal_bytes + wal_fpi_bytes) DESC;

输出：

十一、场景二：定位到库后，进一步查看哪个 Schema 产生最多 WAL

输入：

— 按 schema 维度汇总SELECT database_name, schema_name, SUM(wal_records) AS total_records, pg_size_pretty(SUM(wal_bytes + wal_fpi_bytes)::bigint) AS total_sizeFROM tencentdb_wal_stat(50)WHERE database_name = 'func_veri' — 替换为目标数据库名 AND schema_name IS NOT NULL AND schema_name != ''GROUP BY database_name, schema_nameORDER BY SUM(wal_bytes + wal_fpi_bytes) DESC;

输出：

十二、场景三：精确到表级别，找出 WAL 产生量 TOP10的表

输入：

— 查看产生 WAL 最多的表 TOP10SELECT database_name, schema_name, relation_name, relation_kind, wal_records, pg_size_pretty(wal_bytes::bigint) AS wal_size, pg_size_pretty(wal_fpi_bytes::bigint) AS fpi_size, pg_size_pretty((wal_bytes + wal_fpi_bytes)::bigint) AS total_sizeFROM tencentdb_wal_stat(50)WHERE relation_kind IN ('table', 'index')ORDER BY (wal_bytes + wal_fpi_bytes) DESCLIMIT 10;

输出：

十三、场景四：分析 WAL 类型分布（Heap 写入 vs Index 写入）

输入：

— 按 RMGR 类型查看 WAL 分布SELECT rmgr_name, SUM(wal_records) AS total_records, pg_size_pretty(SUM(wal_bytes)::bigint) AS wal_size, ROUND(SUM(wal_records) * 100.0 / SUM(SUM(wal_records)) OVER (), 1) AS pctFROM tencentdb_wal_stat(50)GROUP BY rmgr_nameORDER BY SUM(wal_records) DESC;

输出：

注意：说明：

注意：Btree 和 Heap 类型占比高说明表写入（INSERT/UPDATE/DELETE）及其关联的索引维护是 WAL 的主要来源。如果 Btree 占比异常高，可考虑减少不必要的索引。

十四、场景五：查看 FPI（Full Page Image）占比

输入：

— FPI 占比分析SELECT pg_size_pretty(SUM(wal_bytes)::bigint) AS wal_data_size, pg_size_pretty(SUM(wal_fpi_bytes)::bigint) AS fpi_size, pg_size_pretty(SUM(wal_bytes + wal_fpi_bytes)::bigint) AS total_size, ROUND(SUM(wal_fpi_bytes) * 100.0 / NULLIF(SUM(wal_bytes + wal_fpi_bytes), 0), 1) AS fpi_pctFROM tencentdb_wal_stat(50);

输出：

注意：说明：

注意：如果 FPI 占比超过40%，可以考虑调大 max_wal_size 来减少 checkpoint 频率，从而降低 FPI 产生量。

十六、WAL 堆积应急处理流程

当收到磁盘空间告警或发现 WAL 堆积时，按照以下步骤排查：

步骤1: 查看整体 WAL 产生概况 └── tencentdb_wal_stat(50) 按 database 汇总 │步骤2: 定位目标数据库 └── 按 schema 汇总，找到异常 schema │步骤3: 精确到表 └── 按 relation 查看 TOP10表 │步骤4: 分析原因 ├── Heap 类型多 → 大量 INSERT/UPDATE/DELETE ├── Btree 类型多 → 索引维护开销大 └── FPI 占比高 → checkpoint 过于频繁 │步骤5: 采取措施 ├── 限制异常租户写入速率 ├── 暂停非核心批量任务 └── 优化索引策略

十七、日常监控建议

建议定期执行以下查询，记录 WAL 产生趋势：

— 每小时记录各数据库 WAL 产生量（可写入监控表）INSERT INTO wal_monitor_log (check_time, database_name, wal_records, wal_bytes)SELECT now(), database_name, SUM(wal_records), SUM(wal_bytes + wal_fpi_bytes)FROM tencentdb_wal_stat(10)GROUP BY database_name;

十八、wal_num 参数选择建议

注意：说明：

注意：wal_num 越大，分析时间越长。建议在业务低峰期执行大范围分析。

十九、名词解释

20、注意事项

·仅主库可用：在备库上执行会报错，这是因为备库没有独立的 WAL 写入。

·权限要求：需要 pg_tencentdb_superuser 角色成员权限。

·参数范围：wal_num 取值1 ~ 500，超出范围会报错。

·名称解析：其他数据库中的对象名称可能显示为 <oid:N> 或 <filenode:N>，这是正常现象（跨库无法解析 catalog）。

·性能影响：该函数读取 WAL 文件进行统计，wal_num 较大时执行时间会增加，建议避免在高峰期使用大 wal_num。

·WAL 可用性：仅能分析尚未被清理的 WAL 文件，已回收的历史 WAL 无法分析。