PGXC_STAT_WAL
PGXC_STAT_WAL视图显示当前query的wal日志和数据页的流量信息，该视图仅8.2.0及以上集群版本支持。
|
名称 |
类型 |
描述 |
|---|---|---|
|
query_id |
bigint |
当前query的ID。 |
|
query_start |
timestamp |
query起始时间。 |
|
global_wal |
bigint |
当前query在集群产生的wal日志总量，单位是Byte。 |
|
global_avg_wal_speed |
bigint |
当前query在集群产生wal日志的平均速率，单位是Byte/s。 |
|
global_datapage |
bigint |
当前query在集群产生的数据页总量，单位是Byte。 |
|
global_avg_datapage_speed |
bigint |
当前query在集群产生数据页的平均速率，单位是Byte/s。 |
|
min_wal_node |
Text |
当前query产生wal日志量最小的实例组名。 |
|
min_wal |
bigint |
最小node产生的wal日志量，单位是Byte。 |
|
max_wal_node |
Text |
当前query产生wal日志量最大的实例组名。 |
|
max_wal |
bigint |
最大node产生的wal日志量，单位是Byte。 |
|
min_datapage_node |
Text |
当前query产生数据页量最小的实例组名。 |
|
min_data_page |
bigint |
最小node产生的数据页量，单位是Byte。 |
|
max_datapage_node |
Text |
当前query产生数据页量最大的实例组名。 |
|
max_data_page |
bigint |
最大node产生的数据页量，单位是Byte。 |
|
avg_wal_per_node |
bigint |
平均每个node产生的wal日志量，单位是Byte。 |
|
avg_datapage_per_node |
bigint |
平均每个node产生的数据页量，单位是Byte。 |
|
query |
Text |
当前执行的语句。 |
行存不带索引批量导入时，数据页copy导入会产生logical newpage相关的xlog日志，在xlog量大于默认值时同样会触发流控。
应用示例
查询集群当前正在执行的语句，以及这些语句分别产生的wal日志的总量和平均速率、数据页总量和平均速率，以及这些信息各自DN上的分布情况。
1 2 3 4 5 6 7 8 9 10 |
SELECT * FROM PGXC_STAT_WAL; query_id | query_start | global_wal | global_avg_wal_speed | global_datapage | global_avg_datapage_speed | min_wal_node | min_wal | max_wal_node | max_wal | min_datapage_node | min_data_page | max_datapage_node | max_data_page | avg_wal_per_node | avg_datapage_per_node | query -------------------+-------------------------------+------------+----------------------+-----------------+---------------------------+--------------+----------+--------------+----------+-------------------+---------------+-------------------+---------------+------------------+- ----------------------+---------------------------------------------- 72620543991351767 | 2022-11-10 16:49:47.743291+08 | 7579052 | 419000 | 284057600 | 15740000 | datanode1 | 7579052 | datanode1 | 7579052 | datanode1 | 284057600 | datanode1 | 284057600 | 7579052 | 284057600 | insert into mpptest3 select * from mpptest3; 72620543991351781 | 2022-11-10 16:50:00.616697+08 | 55022176 | 10638000 | 0 | 0 | datanode1 | 55022176 | datanode1 | 55022176 | datanode1 | 0 | datanode1 | 0 | 55022176 | 0 | insert into mpptest1 select * from mpptest1; (2 rows) |
