当前位置: 首页 > 图灵资讯 > 技术篇> PostgreSQL DBA最常用SQL

PostgreSQL DBA最常用SQL

来源:图灵教育
时间:2023-06-30 16:28:08

背景

建立视图, 方便查询

create schema dba;  create view dba.invalid_index as select indisvalid, indexrelid::regclass, indrelid::regclass, pg_get_indexdef(indexrelid) from pg_index where not indisvalid;  create view dba.ro_conflicts as select datname,pg_stat_get_db_conflict_all(oid) conflict_all,pg_stat_get_db_conflict_bufferpin(oid) conflict_bufferpin,pg_stat_get_db_conflict_lock(oid) conflict_lock,pg_stat_get_db_conflict_snapshot(oid) conflict_snapshot,pg_stat_get_db_conflict_startup_deadlock(oid) conflict_deadlock,pg_stat_get_db_conflict_tablespace(oid) conflict_tbs from pg_database;create or replace procedure dba.tps() as $$declare  v1 int8;  v2 int8;begin  select txid_snapshot_xmax(txid_current_snapshot()) into v1;  commit;  perform pg_sleep(1);  select txid_snapshot_xmax(txid_current_snapshot()) into v2;  commit;  raise notice 'tps: %', v2-v1;end;$$ language plpgsql ;  -- 在主节点查询createe view dba.ro_delay as select application_name,client_addr,client_port,write_lag,replay_lag,sync_state from pg_stat_replication ;    -- 在standby节点执行, 检查replay比receive的延迟createe view dba.node_delay as select * from pg_size_pretty(pg_wal_lsn_diff(pg_last_wal_receive_lsn(),pg_last_wal_replay_lsn())) as t(delay);  -- 在standby节点执行, 检查receiver接收wal比上游产生wal延迟. create view dba.ro_delay_on_standby as select pg_size_pretty(pg_wal_lsn_diff(latest_end_lsn , received_lsn)) from pg_stat_wal_receiver;  -- 在standby节点执行, 接收wal的速度。CREATE OR REPLACE PROCEDURE dba.wal_receive_bw() LANGUAGE plpgsqlAS $procedure$declare  v1 pg_lsn;  v2 pg_lsn;begin  select pg_last_wal_receive_lsn() into v1;  commit;  perform pg_sleep(1);  select pg_last_wal_receive_lsn() into v2;  commit;  raise notice 'wal receive bw: %/s', pg_size_pretty(pg_wal_lsn_diff(v2,v1);end;$procedure$;-- 在standby节点执行, replay wal的速度。 CREATE OR REPLACE PROCEDURE dba.wal_replay_bw() LANGUAGE plpgsqlAS $procedure$declare  v1 pg_lsn;  v2 pg_lsn;begin  select pg_last_wal_replay_lsn() into v1;  commit;  perform pg_sleep(1);  select pg_last_wal_replay_lsn() into v2;  commit;  raise notice 'wal replay bw: %/s', pg_size_pretty(pg_wal_lsn_diff(v2,v1);end;$procedure$;  create view dba.topsql as select calls,total_time,total_time/calls,query from pg_stat_statements where query !~ 'rds' order by total_time desc limit 5;    create view dba.qps as with                                                 a as (select sum(calls) s from pg_stat_statements),     b as (select sum(calls) s from pg_stat_statements , pg_sleep(1))     select     b.s-a.s          -- QPS    from a,b;     create view dba.session_acting_cnt as select count(*) from pg_stat_activity where wait_event is not null and (backend_xid is not null or backend_xmin is not null);    create view dba.sessions as select * from pg_stat_activity where wait_event is not null and (backend_xid is not null or backend_xmin is not null);    create view dba.locks as with      t_wait as      (        select a.mode,a.locktype,a.database,a.relation,a.page,a.tuple,a.classid,a.granted,       a.objid,a.objsubid,a.pid,a.virtualtransaction,a.virtualxid,a.transactionid,a.fastpath,        b.state,b.query,b.xact_start,b.query_start,b.usename,b.datname,b.client_addr,b.client_port,b.application_name         from pg_locks a,pg_stat_activity b where a.pid=b.pid and not a.granted     ),     t_run as     (       select a.mode,a.locktype,a.database,a.relation,a.page,a.tuple,a.classid,a.granted,       a.objid,a.objsubid,a.pid,a.virtualtransaction,a.virtualxid,a.transactionid,a.fastpath,       b.state,b.query,b.xact_start,b.query_start,b.usename,b.datname,b.client_addr,b.client_port,b.application_name         from pg_locks a,pg_stat_activity b where a.pid=b.pid and a.granted     ),     t_overlap as     (       select r.* from t_wait w join t_run r on       (         r.locktype is not distinct from w.locktype and         r.database is not distinct from w.database and         r.relation is not distinct from w.relation and         r.page is not distinct from w.page and         r.tuple is not distinct from w.tuple and         r.virtualxid is not distinct from w.virtualxid and         r.transactionid is not distinct from w.transactionid and         r.classid is not distinct from w.classid and         r.objid is not distinct from w.objid and         r.objsubid is not distinct from w.objsubid and         r.pid <> w.pid       )      ),      t_unionall as      (        select r.* from t_overlap r        union all        select w.* from t_wait w      )      select locktype,datname,relation::regclass,page,tuple,virtualxid,transactionid::text,classid::regclass,objid,objsubid,     string_agg(     'Pid: ||case when pid is null then 'NULL' else pid::text |chr(10)|     'Lock_Granted: ||case when granted is null then 'NULL' else granted::text |||| , Mode: ||case when mode is null then 'NULL' else mode::text |||| , FastPath: ||case when fastpath is null then 'NULL' else fastpath::text |||| , VirtualTransaction: '||case when virtualtransaction is null then 'NULL' else virtualtransaction::text |||||||| , Session_State: ||case when state is null then 'NULL' else state::text |chr(10)|     'Username: ||case when usename is null then 'NULL' else usename::text |||| , Database: ||case when datname is null then 'NULL' else datname::text |||| , Client_Addr: ||case when client_addr is null then 'NULL' else client_addr::text |||| , Client_Port: ||case when client_port is null then 'NULL' else client_port::text |||| , Application_Name: ||case when application_name is null then 'NULL' else application_name::text |chr(10)|      'Xact_Start: ||case when xact_start is null then 'NULL' else xact_start::text |||||||| , Query_Start: ||case when query_start is null then 'NULL' else query_start::text |||| , Xact_Elapse: '||case when (now()-xact_start) is null then 'NULL' else (now()-xact_start)::text |||| , Query_Elapse: ||case when (now()-query_start) is null then 'NULL' else (now()-query_start)::text |chr(10)|      'SQL (Current SQL in Transaction): ||chr(10)|    case when query is null then 'NULL' else query::text end,      chr(10)|||||chr(10)      order by        (  case mode          when 'INVALID' then 0         when 'AccessShareLock' then 1         when 'RowShareLock' then 2         when 'RowExclusiveLock' then 3         when 'ShareUpdateExclusiveLock' then 4         when 'ShareLock' then 5         when 'ShareRowExclusiveLock' then 6         when 'ExclusiveLock' then 7         when 'AccessExclusiveLock' then 8         else 0       end  ) desc,       (case when granted then 0 else 1 end)    ) as lock_conflict    from t_unionall     group by     locktype,datname,relation,page,tuple,virtualxid,transactionid::text,classid,objid,objsubid ;      create view dba.top10sizetable as   select schemaname,tablename,pg_size_pretty(pg_relation_size((quote_ident(schemaname)||'.||quote_ident(tablename))::regclass)) from pg_tables order by pg_relation_size((quote_ident(schemaname)||'.||quote_ident(tablename))::regclass) desc limit 10;    create view dba.top10sizindex as   select schemaname,tablename,indexname,pg_size_pretty(pg_relation_size((quote_ident(schemaname)||'.||quote_ident(indexname))::regclass)) from pg_indexes order by pg_relation_size((quote_ident(schemaname)||'.||quote_ident(indexname))::regclass) desc limit 10;    create view dba.10sizetableindextop as   select schemaname,tablename,pg_size_pretty(pg_total_relation_size((quote_ident(schemaname)||'.||quote_ident(tablename))::regclass)) from pg_tables order by pg_total_relation_size((quote_ident(schemaname)||'.||quote_ident(tablename))::regclass) desc limit 10;    create view dba.top10updatetabletttabletttatettable as  select schemaname,relname,n_tup_upd,n_tup_del,round(n_tup_hot_upd/(case when n_tup_upd=0 then 1.0 else n_tup_upd::numeric end),4) from pg_stat_all_tables order by n_tup_upd+n_tup_del desc limit 10;    create view dba.tabletttop10inserttatter as  select schemaname,relname,n_tup_ins from pg_stat_all_tables order by n_tup_ins desc limit 10;    create view dba.top10deadtabletttable as  select schemaname,relname,n_dead_tup from pg_stat_all_tables order by n_dead_tup desc limit 10;    create view dba.top10age as  select relnamespace::regnamespace,relname,pg_size_pretty(pg_relation_size(oid)),age(relfrozenxid) from pg_class where relkind='r' and relnamespace<>'pg_catalog'::regnamespace and relnamespace<>'information_schema'::regnamespace order by age(relfrozenxid) desc,pg_relation_size(oid) desc limit 10;    -- 膨胀点查询createeter view dba.oldestxact asselect datname,usename,xact_start,query_start,backend_xid,backend_xmin,now()-xact_start as old_ts,txid_current()-least(backend_xid::text::int8,backend_xmin::text::int8) as old_xacts,query from pg_stat_activity where ltrim(lower(query),' ') !~ '^vacuum'and not (query ~ 'autovacuum' and backend_type <>'client backend')order by least(backend_xid::text::int8,backend_xmin::text::int8) limit 1;  -- 查询膨胀空间top 10的表  create view dba.top10blotsizetable as  SELECT    current_database() AS db, schemaname, tablename, reltuples::bigint AS tups, relpages::bigint AS pages, otta,    ROUND(CASE WHEN otta=0 OR sml.relpages=0 OR sml.relpages=otta THEN 0.0 ELSE sml.relpages/otta::numeric END,1) AS tbloat,    CASE WHEN relpages < otta THEN 0 ELSE relpages::bigint - otta END AS wastedpages,    CASE WHEN relpages < otta THEN 0 ELSE bs*(sml.relpages-otta)::bigint END AS wastedbytes,    CASE WHEN relpages < otta THEN '0 bytes'::text ELSE pg_size_pretty((bs*(relpages-otta))::bigint) END AS wastedsize,    iname, ituples::bigint AS itups, ipages::bigint AS ipages, iotta,    ROUND(CASE WHEN iotta=0 OR ipages=0 OR ipages=iotta THEN 0.0 ELSE ipages/iotta::numeric END,1) AS ibloat,    CASE WHEN ipages < iotta THEN 0 ELSE ipages::bigint - iotta END AS wastedipages,    CASE WHEN ipages < iotta THEN 0 ELSE bs*(ipages-iotta) END AS wastedibytes,    CASE WHEN ipages < iotta THEN '0 bytes' ELSE pg_size_pretty((bs*(ipages-iotta))::bigint) END AS wastedisize,    pg_size_pretty(CASE WHEN relpages < otta THEN      CASE WHEN ipages < iotta THEN 0 ELSE bs*(ipages-iotta::bigint) END      ELSE CASE WHEN ipages < iotta THEN bs*(relpages-otta::bigint)        ELSE bs*(relpages-otta::bigint + ipages-iotta::bigint) END    END) AS totalwastedbytes  FROM (    SELECT      nn.nspname AS schemaname,      cc.relname AS tablename,      COALESCE(cc.reltuples,0) AS reltuples,      COALESCE(cc.relpages,0) AS relpages,      COALESCE(bs,0) AS bs,      COALESCE(CEIL((cc.reltuples*((datahdr+ma-        (CASE WHEN datahdr%ma=0 THEN ma ELSE datahdr%ma END))+nullhdr2+4)(bs-20::float)),0) AS otta,      COALESCE(c2.relname,'?') AS iname, COALESCE(c2.reltuples,0) AS ituples, COALESCE(c2.relpages,0) AS ipages,      COALESCE(CEIL((c2.reltuples*(datahdr-12))/(bs-20::float)),0) AS iotta -- very rough approximation, assumes all cols    FROM       pg_class cc    JOIN pg_namespace nn ON cc.relnamespace = nn.oid AND nn.nspname <> 'information_schema'    LEFT JOIN    (      SELECT        ma,bs,foo.nspname,foo.relname,        (datawidth+(hdr+ma-(case when hdr%ma=0 THEN ma ELSE hdr%ma END)))::numeric AS datahdr,        (maxfracsum*(nullhdr+ma-(case when nullhdr%ma=0 THEN ma ELSE nullhdr%ma END))) AS nulllhdr2      FROM (        SELECT          ns.nspname, tbl.relname, hdr, ma, bs,          SUM((1-coalesce(null_frac,0))*coalesce(avg_width, 2048)) AS datawidth,          MAX(coalesce(null_frac,0)) AS maxfracsum,          hdr+(            SELECT 1+count(*)/8            FROM pg_stats s2            WHERE null_frac<>0 AND s2.schemaname = ns.nspname AND s2.tablename = tbl.relname          ) AS nullhdr        FROM pg_attribute att        JOIN pg_class tbl ON att.attrelid = tbl.oid        JOIN pg_namespace ns ON ns.oid = tbl.relnamespace        LEFT JOIN pg_stats s ON s.schemaname=ns.nspname        AND s.tablename = tbl.relname        AND s.inherited=false        AND s.attname=att.attname,        (          SELECT            (SELECT current_setting('block_size')::numeric) AS bs,              CASE WHEN SUBSTRING(SPLIT_PART(v, ' ', 2) FROM '#"[0-9]+.[0-9]+# for '#')                IN 8.0,8.1,8.2 THEN 27 ELSE 23 END AS hdr,            CASE WHEN v ~ "mingw32" OR v ~ '64-bit' THEN 8 ELSE 4 END AS ma          FROM (SELECT version() AS v) AS foo        ) AS constants        WHERE att.attnum > 0 AND tbl.relkind='r'        GROUP BY 1,2,3,4,5      ) AS foo    ) AS rs    ON cc.relname = rs.relname AND nn.nspname = rs.nspname    LEFT JOIN pg_index i ON indrelid = cc.oid    LEFT JOIN pg_class c2 ON c2.oid = i.indexrelid  ) AS sml order by wastedbytes desc limit 5;    -- 查询膨胀空间top 10的索引  create view dba.10bloatsizeindextop as  SELECT    current_database() AS db, schemaname, tablename, reltuples::bigint AS tups, relpages::bigint AS pages, otta,    ROUND(CASE WHEN otta=0 OR sml.relpages=0 OR sml.relpages=otta THEN 0.0 ELSE sml.relpages/otta::numeric END,1) AS tbloat,    CASE WHEN relpages < otta THEN 0 ELSE relpages::bigint - otta END AS wastedpages,    CASE WHEN relpages < otta THEN 0 ELSE bs*(sml.relpages-otta)::bigint END AS wastedbytes,    CASE WHEN relpages < otta THEN '0 bytes'::text ELSE pg_size_pretty((bs*(relpages-otta))::bigint) END AS wastedsize,    iname, ituples::bigint AS itups, ipages::bigint AS ipages, iotta,    ROUND(CASE WHEN iotta=0 OR ipages=0 OR ipages=iotta THEN 0.0 ELSE ipages/iotta::numeric END,1) AS ibloat,    CASE WHEN ipages < iotta THEN 0 ELSE ipages::bigint - iotta END AS wastedipages,    CASE WHEN ipages < iotta THEN 0 ELSE bs*(ipages-iotta) END AS wastedibytes,    CASE WHEN ipages < iotta THEN '0 bytes' ELSE pg_size_pretty((bs*(ipages-iotta))::bigint) END AS wastedisize,    pg_size_pretty(CASE WHEN relpages < otta THEN      CASE WHEN ipages < iotta THEN 0 ELSE bs*(ipages-iotta::bigint) END      ELSE CASE WHEN ipages < iotta THEN bs*(relpages-otta::bigint)        ELSE bs*(relpages-otta::bigint + ipages-iotta::bigint) END    END) AS totalwastedbytes  FROM (    SELECT      nn.nspname AS schemaname,      cc.relname AS tablename,      COALESCE(cc.reltuples,0) AS reltuples,      COALESCE(cc.relpages,0) AS relpages,      COALESCE(bs,0) AS bs,      COALESCE(CEIL((cc.reltuples*((datahdr+ma-        (CASE WHEN datahdr%ma=0 THEN ma ELSE datahdr%ma END))+nullhdr2+4)(bs-20::float)),0) AS otta,      COALESCE(c2.relname,'?') AS iname, COALESCE(c2.reltuples,0) AS ituples, COALESCE(c2.relpages,0) AS ipages,      COALESCE(CEIL((c2.reltuples*(datahdr-12))/(bs-20::float)),0) AS iotta -- very rough approximation, assumes all cols    FROM       pg_class cc    JOIN pg_namespace nn ON cc.relnamespace = nn.oid AND nn.nspname <> 'information_schema'    LEFT JOIN    (      SELECT        ma,bs,foo.nspname,foo.relname,        (datawidth+(hdr+ma-(case when hdr%ma=0 THEN ma ELSE hdr%ma END)))::numeric AS datahdr,        (maxfracsum*(nullhdr+ma-(case when nullhdr%ma=0 THEN ma ELSE nullhdr%ma END))) AS nullhdr2      FROM (        SELECT          ns.nspname, tbl.relname, hdr, ma, bs,          SUM((1-coalesce(null_frac,0))*coalesce(avg_width, 2048)) AS datawidth,          MAX(coalesce(null_frac,0)) AS maxfracsum,          hdr+(            SELECT 1+count(*)/8            FROM pg_stats s2            WHERE null_frac<>0 AND s2.schemaname = ns.nspname AND s2.tablename = tbl.relname          ) AS nullhdr        FROM pg_attribute att        JOIN pg_class tbl ON att.attrelid = tbl.oid        JOIN pg_namespace ns ON ns.oid = tbl.relnamespace        LEFT JOIN pg_stats s ON s.schemaname=ns.nspname        AND s.tablename = tbl.relname        AND s.inherited=false        AND s.attname=att.attname,        (          SELECT            (SELECT current_setting('block_size')::numeric) AS bs,              CASE WHEN SUBSTRING(SPLIT_PART(v, ' ', 2) FROM '#"[0-9]+.[0-9]+# for '#')                IN 8.0,8.1,8.2 THEN 27 ELSE 23 END AS hdr,            CASE WHEN v ~ "mingw32" OR v ~ '64-bit' THEN 8 ELSE 4 END AS ma          FROM (SELECT version() AS v) AS foo        ) AS constants        WHERE att.attnum > 0 AND tbl.relkind='r'        GROUP BY 1,2,3,4,5      ) AS foo    ) AS rs    ON cc.relname = rs.relname AND nn.nspname = rs.nspname    LEFT JOIN pg_index i ON indrelid = cc.oid    LEFT JOIN pg_class c2 ON c2.oid = i.indexrelid  ) AS sml order by wastedibytes desc limit 5;    -- 查询膨胀比例top 10表(浪费空间大于10MB的表)  create view dba.top10bloatratiotable as  SELECT    current_database() AS db, schemaname, tablename, reltuples::bigint AS tups, relpages::bigint AS pages, otta,    ROUND(CASE WHEN otta=0 OR sml.relpages=0 OR sml.relpages=otta THEN 0.0 ELSE sml.relpages/otta::numeric END,1) AS tbloat,    CASE WHEN relpages < otta THEN 0 ELSE relpages::bigint - otta END AS wastedpages,    CASE WHEN relpages < otta THEN 0 ELSE bs*(sml.relpages-otta)::bigint END AS wastedbytes,    CASE WHEN relpages < otta THEN '0 bytes'::text ELSE pg_size_pretty((bs*(relpages-otta))::bigint) END AS wastedsize,    iname, ituples::bigint AS itups, ipages::bigint AS ipages, iotta,    ROUND(CASE WHEN iotta=0 OR ipages=0 OR ipages=iotta THEN 0.0 ELSE ipages/iotta::numeric END,1) AS ibloat,    CASE WHEN ipages < iotta THEN 0 ELSE ipages::bigint - iotta END AS wastedipages,    CASE WHEN ipages < iotta THEN 0 ELSE bs*(ipages-iotta) END AS wastedibytes,    CASE WHEN ipages < iotta THEN '0 bytes' ELSE pg_size_pretty((bs*(ipages-iotta))::bigint) END AS wastedisize,    pg_size_pretty(CASE WHEN relpages < otta THEN      CASE WHEN ipages < iotta THEN 0 ELSE bs*(ipages-iotta::bigint) END      ELSE CASE WHEN ipages < iotta THEN bs*(relpages-otta::bigint)        ELSE bs*(relpages-otta::bigint + ipages-iotta::bigint) END    END) AS totalwastedbytes  FROM (    SELECT      nn.nspname AS schemaname,      cc.relname AS tablename,      COALESCE(cc.reltuples,0) AS reltuples,      COALESCE(cc.relpages,0) AS relpages,      COALESCE(bs,0) AS bs,      COALESCE(CEIL((cc.reltuples*((datahdr+ma-        (CASE WHEN datahdr%ma=0 THEN ma ELSE datahdr%ma END))+nullhdr2+4)(bs-20::float)),0) AS otta,      COALESCE(c2.relname,'?') AS iname, COALESCE(c2.reltuples,0) AS ituples, COALESCE(c2.relpages,0) AS ipages,      COALESCE(CEIL((c2.reltuples*(datahdr-12))/(bs-20::float)),0) AS iotta -- very rough approximation, assumes all cols    FROM       pg_class cc    JOIN pg_namespace nn ON cc.relnamespace = nn.oid AND nn.nspname <> 'information_schema'    LEFT JOIN    (      SELECT        ma,bs,foo.nspname,foo.relname,        (datawidth+(hdr+ma-(case when hdr%ma=0 THEN ma ELSE hdr%ma END)))::numeric AS datahdr,        (maxfracsum*(nullhdr+ma-(case when nullhdr%ma=0 THEN ma ELSE nullhdr%ma END))) AS nulllhdr2      FROM (        SELECT          ns.nspname, tbl.relname, hdr, ma, bs,          SUM((1-coalesce(null_frac,0))*coalesce(avg_width, 2048)) AS datawidth,          MAX(coalesce(null_frac,0)) AS maxfracsum,          hdr+(            SELECT 1+count(*)/8            FROM pg_stats s2            WHERE null_frac<>0 AND s2.schemaname = ns.nspname AND s2.tablename = tbl.relname          ) AS nullhdr        FROM pg_attribute att        JOIN pg_class tbl ON att.attrelid = tbl.oid        JOIN pg_namespace ns ON ns.oid = tbl.relnamespace        LEFT JOIN pg_stats s ON s.schemaname=ns.nspname        AND s.tablename = tbl.relname        AND s.inherited=false        AND s.attname=att.attname,        (          SELECT            (SELECT current_setting('block_size')::numeric) AS bs,              CASE WHEN SUBSTRING(SPLIT_PART(v, ' ', 2) FROM '#"[0-9]+.[0-9]+#"%' for '#')                IN 8.0,8.1,8.2 THEN 27 ELSE 23 END AS hdr,            CASE WHEN v ~ "mingw32" OR v ~ '64-bit' THEN 8 ELSE 4 END AS ma          FROM (SELECT version() AS v) AS foo        ) AS constants        WHERE att.attnum > 0 AND tbl.relkind='r'        GROUP BY 1,2,3,4,5      ) AS foo    ) AS rs    ON cc.relname = rs.relname AND nn.nspname = rs.nspname    LEFT JOIN pg_index i ON indrelid = cc.oid    LEFT JOIN pg_class c2 ON c2.oid = i.indexrelid  ) AS sml   where (CASE WHEN relpages < otta THEN 0 ELSE bs*(sml.relpages-otta)::bigint END) >= 10240000  order by tbloat desc,wastedbytes desc limit 5;    -- 查询膨胀比例top 10索引(浪费空间大于10MB的索引)  create view dba.10bloatratioindextop as  SELECT    current_database() AS db, schemaname, tablename, reltuples::bigint AS tups, relpages::bigint AS pages, otta,    ROUND(CASE WHEN otta=0 OR sml.relpages=0 OR sml.relpages=otta THEN 0.0 ELSE sml.relpages/otta::numeric END,1) AS tbloat,    CASE WHEN relpages < otta THEN 0 ELSE relpages::bigint - otta END AS wastedpages,    CASE WHEN relpages < otta THEN 0 ELSE bs*(sml.relpages-otta)::bigint END AS wastedbytes,    CASE WHEN relpages < otta THEN '0 bytes'::text ELSE pg_size_pretty((bs*(relpages-otta))::bigint) END AS wastedsize,    iname, ituples::bigint AS itups, ipages::bigint AS ipages, iotta,    ROUND(CASE WHEN iotta=0 OR ipages=0 OR ipages=iotta THEN 0.0 ELSE ipages/iotta::numeric END,1) AS ibloat,    CASE WHEN ipages < iotta THEN 0 ELSE ipages::bigint - iotta END AS wastedipages,    CASE WHEN ipages < iotta THEN 0 ELSE bs*(ipages-iotta) END AS wastedibytes,    CASE WHEN ipages < iotta THEN '0 bytes' ELSE pg_size_pretty((bs*(ipages-iotta))::bigint) END AS wastedisize,    pg_size_pretty(CASE WHEN relpages < otta THEN      CASE WHEN ipages < iotta THEN 0 ELSE bs*(ipages-iotta::bigint) END      ELSE CASE WHEN ipages < iotta THEN bs*(relpages-otta::bigint)        ELSE bs*(relpages-otta::bigint + ipages-iotta::bigint) END    END) AS totalwastedbytes  FROM (    SELECT      nn.nspname AS schemaname,      cc.relname AS tablename,      COALESCE(cc.reltuples,0) AS reltuples,      COALESCE(cc.relpages,0) AS relpages,      COALESCE(bs,0) AS bs,      COALESCE(CEIL((cc.reltuples*((datahdr+ma-        (CASE WHEN datahdr%ma=0 THEN ma ELSE datahdr%ma END))+nullhdr2+4)(bs-20::float)),0) AS otta,      COALESCE(c2.relname,'?') AS iname, COALESCE(c2.reltuples,0) AS ituples, COALESCE(c2.relpages,0) AS ipages,      COALESCE(CEIL((c2.reltuples*(datahdr-12))/(bs-20::float)),0) AS iotta -- very rough approximation, assumes all cols    FROM       pg_class cc    JOIN pg_namespace nn ON cc.relnamespace = nn.oid AND nn.nspname <> 'information_schema'    LEFT JOIN    (      SELECT        ma,bs,foo.nspname,foo.relname,        (datawidth+(hdr+ma-(case when hdr%ma=0 THEN ma ELSE hdr%ma END)))::numeric AS datahdr,        (maxfracsum*(nullhdr+ma-(case when nullhdr%ma=0 THEN ma ELSE nullhdr%ma END))) AS nulllhdr2      FROM (        SELECT          ns.nspname, tbl.relname, hdr, ma, bs,          SUM((1-coalesce(null_frac,0))*coalesce(avg_width, 2048)) AS datawidth,          MAX(coalesce(null_frac,0)) AS maxfracsum,          hdr+(            SELECT 1+count(*)/8            FROM pg_stats s2            WHERE null_frac<>0 AND s2.schemaname = ns.nspname AND s2.tablename = tbl.relname          ) AS nullhdr        FROM pg_attribute att        JOIN pg_class tbl ON att.attrelid = tbl.oid        JOIN pg_namespace ns ON ns.oid = tbl.relnamespace        LEFT JOIN pg_stats s ON s.schemaname=ns.nspname        AND s.tablename = tbl.relname        AND s.inherited=false        AND s.attname=att.attname,        (          SELECT            (SELECT current_setting('block_size')::numeric) AS bs,              CASE WHEN SUBSTRING(SPLIT_PART(v, ' ', 2) FROM '#"[0-9]+.[0-9]+# for '#')                IN 8.0,8.1,8.2 THEN 27 ELSE 23 END AS hdr,            CASE WHEN v ~ "mingw32" OR v ~ '64-bit' THEN 8 ELSE 4 END AS ma          FROM (SELECT version() AS v) AS foo        ) AS constants        WHERE att.attnum > 0 AND tbl.relkind='r'        GROUP BY 1,2,3,4,5      ) AS foo    ) AS rs    ON cc.relname = rs.relname AND nn.nspname = rs.nspname    LEFT JOIN pg_index i ON indrelid = cc.oid    LEFT JOIN pg_class c2 ON c2.oid = i.indexrelid  ) AS sml   where (CASE WHEN ipages < iotta THEN 0 ELSE bs*(ipages-iotta) END) >= 10240000  order by ibloat desc,wastedibytes desc limit 5;    create view dba.seqs as select max_value-last_value,* from pg_sequences order by max_value-last_value ;  -- 未使用的索引大于1MB top 10 (注意, PK、如果UK只用于约束, 统计数可能不会计算,但不能删除)    create view dba.10notusedidxtop as     select pg_size_pretty(pg_relation_size(indexrelid)),* from pg_stat_all_indexes where pg_relation_size(indexrelid)>=1024000 and (idx_scan=0 or idx_tup_read=0 or idx_tup_fetch=0)    and schemaname not in ('pg_toast','pg_catalog') order by pg_relation_size(indexrelid) desc limit 10;        -- 查询未使用的大于1MB的表 top 10     create view dba.10notusedtabtop as     select pg_size_pretty(pg_relation_size(relid)),* from pg_stat_all_tables     where pg_relation_size(relid)>=1024000 and seq_scan=0 and idx_scan=0 and schemaname not in ('pg_toast','pg_catalog','information_schema') order by pg_relation_size(relid) desc limit 10;        -- 查询热表top 10    create view dba.10hottabtop10 as     select pg_size_pretty(pg_relation_size(relid)),* from pg_stat_all_tables where schemaname not in ('pg_toast','pg_catalog','information_schema') order by seq_scan+idx_scan desc, pg_relation_size(relid) desc limit 10;          -- 冷表top查询大于1MB 10    create view dba.top10coldtabttatttabtttop as     select pg_size_pretty(pg_relation_size(relid)),* from pg_stat_all_tables where schemaname not in ('pg_toast','pg_catalog','information_schema') and pg_relation_size(relid)>=1024000 order by seq_scan+idx_scan,pg_relation_size(relid) desc   limit 10;          -- 查询热索引top 10    create view dba.10hotidxtop as     select pg_size_pretty(pg_relation_size(indexrelid)),* from pg_stat_all_indexes where     schemaname not in ('pg_toast','pg_catalog') order by idx_scan+idx_tup_read+idx_tup_fetch desc, pg_relation_size(indexrelid) desc limit 10;        -- 冷索引top,查询大于1MB 10(注意, PK、如果UK仅用于约束, 也许不会被统计计数,但不能删除)    create view dba.top10coldidxttop as     select pg_size_pretty(pg_relation_size(indexrelid)),* from pg_stat_all_indexes where pg_relation_size(indexrelid)>=1024000     and schemaname not in ('pg_toast','pg_catalog') order by idx_scan+idx_tup_read+idx_tup_fetch , pg_relation_size(indexrelid) desc limit 10;      -- 与freeze风暴预测相关的三个视图createe view dba.v_freeze as    select       e.*,       a.*     from    (select       current_setting('autovacuum_freeze_max_age')::int as v1,            -- 假如表中的事务ID年龄大于该值, 即使不打开autovacum,FREEEZE也会被迫触发。 警告Preventing Transaction ID Wraparound Failures      current_setting('autovacuum_multixact_freeze_max_age')::int as v2,  -- 若表并行事务ID年龄大于此值, 即使不打开autovacum,FREEEZE也会被迫触发。 警告Preventing Transaction ID Wraparound Failures      current_setting('vacuum_freeze_min_age')::int as v3,                -- 回收手动或自动垃圾时, 如果记录的事务ID年龄大于该值, 将被FREEZE使用      current_setting('vacuum_multixact_freeze_min_age')::int as v4,      -- 回收手动或自动垃圾时, 如果记录的并行事务ID年龄大于该值, 将被FREEZE使用      current_setting('vacuum_freeze_table_age')::int as v5,              -- 回收手动垃圾时, 假如表中的事务ID年龄大于该值, FREEZE将被触发. 该参数的上限值为 %95 autovacuum_freeze_max_age      current_setting('vacuum_multixact_freeze_table_age')::int as v6,    -- 回收手动垃圾时, 若表并行事务ID年龄大于此值, FREEZE将被触发. 该参数的上限值为 %95 autovacuum_multixact_freeze_max_age      current_setting('autovacuum_vacuum_cost_delay') as v7,              -- 回收自动垃圾时, 每一轮回收周期后的休息时间, 主要防止垃圾回收资源消耗过多. -1 表示沿用vacuum___cost_delay设置      current_setting('autovacuum_vacuum_cost_limit') as v8,              -- 回收自动垃圾时, 每个回收周期设置多少限制, 由vacuum限制cost_page_hit,vacuum_cost_page_missvacuum_cost_page_周期内的dirty参数和操作决定. -1 表示沿用vacuum___cost_limit设置      current_setting('vacuum_cost_delay') as v9,                         -- 回收手动垃圾时, 每一轮回收周期后的休息时间, 主要防止垃圾回收资源消耗过多.      current_setting('vacuum_cost_limit') as v10,                        -- 回收手动垃圾时, 每一轮回收周期有多大限制, vacuum_限制cost_page_hit,vacuum_cost_page_missvacuum_cost_page_dirty参数和周期内的操作决策.      current_setting('autovacuum') as autovacuum                         -- 自动垃圾回收是否开启,自动垃圾回收是否开启    ) a,     LATERAL (   -- LATERAL 允许您在SUBQUERY中直接引用前面的table, columnnsubquery     select     pg_size_pretty(pg_total_relation_size(oid)) sz,   -- 表的大小(包括TOAST, 索引)    oid::regclass as reloid,    -- 表名(物化视图)    relkind,                    -- r=表, m=物化视图    coalesce(      least(        substring(reloptions::text, 'autovacuum_freeze_max_age=(\d+)')::int,         substring(reloptions::text, 'autovacuum_freeze_table_age=(\d+)')::int       ),      a.v1    )    -    age(case when relfrozenxid::text::int<3 then null else relfrozenxid end)     as remain_ages_xid,   -- 在发生多少事务之后, FREEZE会触发自动垃圾回收, 因为事务ID    coalesce(      least(        substring(reloptions::text, 'autovacuum_multixact_freeze_max_age=(\d+)')::int,         substring(reloptions::text, 'autovacuum_multixact_freeze_table_age=(\d+)')::int       ),      a.v2    )    -    age(case when relminmxid::text::int<3 then null else relminmxid end)     as remain_ages_mxid,  -- 在发生多少事务之后, FREEZE会触发自动垃圾回收, 由于并发事务ID    coalesce(      least(        substring(reloptions::text, 'autovacuum_freeze_min_age=(\d+)')::int      ),      a.v3    ) as xid_lower_to_minage,    -- 若触发FREEZE, 这个表的事务ID年龄会降到多少?    coalesce(      least(        substring(reloptions::text, 'autovacuum_multixact_freeze_min_age=(\d+)')::int      ),      a.v4    ) as mxid_lower_to_minage,   -- 若触发FREEZE, 该表的并行事务ID年龄将降至多少?    case       when v5 <= age(case when relfrozenxid::text::int<3 then null else relfrozenxid end) then 'YES'      else 'NOT'    end as vacuum_trigger_freeze1,    -- 如果VACUUM手动执行, 是否会触发FREEZE, 触发原因(事务ID年龄达到阈值)    case       when v6 <= age(case when relminmxid::text::int<3 then null else relminmxid end) then 'YES'      else 'NOT'    end as vacuum_trigger_freeze2,    -- 如果VACUUM手动执行, 是否会触发FREEZE, 触发原因(并行ID年龄达到阈值)    reloptions                        -- 表级参数, 优先. 例如,是否开始自动垃圾回收, autovacuum_freeze_max_age, autovacuum_freeze_table_age, autovacuum_multixact_freeze_max_age, autovacuum_multixact_freeze_table_age    from pg_class       where relkind in ('r','m')    ) e     order by       least(e.remain_ages_xid , e.remain_ages_mxid),  -- 排在越前, 自动FREEZE越先触发, 即风暴来临的预测      pg_total_relation_size(reloid) desc   -- 同样的剩余年龄, 表越大, 排越前    ;    create view dba.v_freeze_stat as    select     wb,                                                     -- 几个BATCH, 每个batch代表100万事务的流失     cnt,                                                    -- 这个batch 有多少表    pg_size_pretty(ssz) as ssz1,                            -- 这个batch 这些 表+TOAST+索引 有多少容量    pg_size_pretty(ssz) as ssz2,                            -- 这个batch FREEZE 会导致多少读IO    pg_size_pretty(ssz*3) as ssz3,                          -- 这个batch FREEZE 最多可能导致多少写IO? (通常三份 : 数据文件, WAL FULL PAGE, WAL)    pg_size_pretty(min_sz) as ssz4,                         -- 这个batch 最小的表有多大    pg_size_pretty(max_sz) as ssz5,                         -- 这个batch 最大的表有多大    pg_size_pretty(avg_sz) as ssz6,                         -- 这个batch 平均表多大    pg_size_pretty(stddev_sz) as ssz7,                      -- 这个batch 表大小的方差, 越大, 说明表大小差异明显    min_rest_age,                                           -- 这个batch 自动FREEZE最低剩余事务数    max_rest_age,                                           -- 这个batch 自动FREEZE的最高剩余事务    stddev_rest_age,                                        -- 这个batch 距离自动FREEZE剩余事务数的方差, batch触发freeze越小,就越平缓。 越大, 这表明batch可能会在某些点集中触发freezee (但可能集中触发的是小表)    corr_rest_age_sz,                                       -- 表大小与自动freeze剩余事务数之间的相关性,相关性越强(值趋势1或-1) stddev_rest_age 与 sz7 解释的问题越有价值    round(100*(ssz/(sum(ssz) over ())), 2)||' %' as ratio   -- 如果BATCH的容量比例非常不均匀,则表级FREEZE参数需要调整,均匀化比例    from         (    select a.*, b.* from     (    select       min(least(remain_ages_xid, remain_ages_mxid)) as v_min,   -- 从自动FREEZE中离开整个数据库的整个数据库 最小 剩余事务ID数      max(least(remain_ages_xid, remain_ages_mxid)) as v_max    -- 从自动FREEZE中离开整个数据库的整个数据库 最大 剩余事务ID数    from v_freeze    ) as a,    LATERAL (  -- 高级SQL    select     width_bucket(      least(remain_ages_xid, remain_ages_mxid),       a.v_min,      a.v_max,      greatest((a.v_max-a.v_min)/1000000, 1)   -- 100万个事务, 例如,如果需要更改统计数据,则可以修改此值    ) as wb,      count(*) as cnt,     sum(pg_total_relation_size(reloid)) as ssz,     stddev_samp(pg_total_relation_size(reloid) order by least(remain_ages_xid, remain_ages_mxid)) as stddev_sz,     min(pg_total_relation_size(reloid)) as min_sz,     max(pg_total_relation_size(reloid)) as max_sz,     avg(pg_total_relation_size(reloid)) as avg_sz,     min(least(remain_ages_xid, remain_ages_mxid)) as min_rest_age,     max(least(remain_ages_xid, remain_ages_mxid)) as max_rest_age,     stddev_samp(least(remain_ages_xid, remain_ages_mxid) order by least(remain_ages_xid, remain_ages_mxid)) as stddev_rest_age,     corr(least(remain_ages_xid, remain_ages_mxid), pg_total_relation_size(reloid)) as corr_rest_age_sz     from v_freeze     group by wb     ) as b     ) t     order by wb; create view dba.v_freeze_stat_detail as      select     pg_size_pretty(t.ssz) as ssz2,     -- 这个batch FREEZE 会导致多少读IO (表+TOAST+索引)    pg_size_pretty(t.ssz*3) as ssz3,   -- 这个batch FREEZE 最多可能导致多少写IO? (通常三份 : 数据文件, WAL FULL PAGE, WAL)    pg_size_pretty(t.ssz_sum) as ssz4, -- 所有batch 所有手表的总尺寸  (表+TOAST+索引)    round(100*(t.ssz/t.ssz_sum), 2)||' %' as ratio_batch,     -- BATCH的容量比,目标是使所有BATCH的比例尽可能一致    round(100*(pg_total_relation_size(t.reloid)/t.ssz), 2)||' %' as ratio_table,     -- 该表占整个batch容量的比例,尽量错开大表的freze    t.*      from         (    select a.*, b.* from       (      select         min(least(remain_ages_xid, remain_ages_mxid)) as v_min,   -- 从自动FREEZE中离开整个数据库的整个数据库 最小 剩余事务ID数        max(least(remain_ages_xid, remain_ages_mxid)) as v_max    -- 从自动FREEZE中离开整个数据库的整个数据库 最大 剩余事务ID数      from v_freeze     ) as a,     LATERAL (     -- 高级SQL    select       count(*) over w as cnt,                                                -- 这个batch 有多少表        sum(pg_total_relation_size(reloid)) over () as ssz_sum,                -- 所有batch 所有手表的总尺寸  (表+TOAST+索引)      sum(pg_total_relation_size(reloid)) over w as ssz,                     -- 这个batch 表大小总和 (表+TOAST+索引)      pg_size_pretty(min(pg_total_relation_size(reloid)) over w) as min_sz,  -- 这个batch 最小的表有多大      pg_size_pretty(max(pg_total_relation_size(reloid)) over w) as max_sz,  -- 这个batch 最大的表有多大      pg_size_pretty(avg(pg_total_relation_size(reloid)) over w) as avg_sz,  -- 这个batch 平均表多大      pg_size_pretty(stddev_samp(pg_total_relation_size(reloid)) over w) as stddev_sz,  -- 这个batch 表大小的方差, 越大, 说明表大小差异明显                                                                                                                   min(least(remain_ages_xid, remain_ages_mxid)) over w as min_rest_age,             -- 这个batch 自动FREEZE最低剩余事务数                                                                                                                               max(least(remain_ages_xid, remain_ages_mxid)) over w as max_rest_age,             -- 这个batch 自动FREEZE的最高剩余事务                                                                                                                               stddev_samp(least(remain_ages_xid, remain_ages_mxid)) over w as stddev_rest_age,  -- 这个batch 自动FREEZE剩余事务数的方差, 越小,这个batch触发freeze就越平缓, 越大, 这表明batch可能会在某些点集中触发freezee (但可能集中触发的是小表)      corr(least(remain_ages_xid, remain_ages_mxid), pg_total_relation_size(reloid)) over w as corr_rest_age_sz,  -- 表大小与自动freeze剩余事务数之间的相关性,相关性越强(值趋势1或-1) stddev_rest_age 与 stddev_sz 说明的问题越有价值      t1.*     from       (      select         width_bucket(          least(tt.remain_ages_xid, tt.remain_ages_mxid),           a.v_min,          a.v_max,          greatest((a.v_max-a.v_min)/1000000, 1)         -- 100万个事务, 例如,如果要改变统计,可以修改这个值        )         as wb,                                           -- 几个BATCH, 每个batch代表100万事务的流失          * from v_freeze tt      ) as t1        window w as       (        partition by t1.wb       )     ) as b    ) t    order by       t.wb,        least(t.remain_ages_xid, t.remain_ages_mxid),         pg_total_relation_size(t.reloid) desc       ;        create view dba.top20frezebigtable as select relowner::regrole, relnamespace::regnamespace, relname, age(relfrozenxid),pg_size_pretty(pg_total_relation_size(oid)) , -- 当前年龄 coalesce(      least(        substring(reloptions::text, 'autovacuum_freeze_max_age=(\d+)')::int,         substring(reloptions::text, 'autovacuum_freeze_table_age=(\d+)')::int       ),      current_setting('autovacuum_freeze_max_age')::int   )    -    age(case when relfrozenxid::text::int<3 then null else relfrozenxid end)     as remain_ages_xid,  -- 在发生多少事务之后, FREEZE会触发自动垃圾回收, 因为事务IDcoalesce(      least(        substring(reloptions::text, 'autovacuum_freeze_min_age=(\d+)')::int      ),      current_setting('vacuum_freeze_min_age')::int   ) as xid_lower_to_minage    -- 假如FREEZE被触发, 该表的事务ID年龄将下降多少?  from pg_class where relkind='r' order by pg_total_relation_size(oid) desc limit 20; -- 未归档wal文件createteteteeatereate view dba.arch_undone as select * from pg_ls_archive_statusdir() where name !~ 'done$';-- 归档任务状态createtetereateteer view dba.arch_status asselect * from pg_stat_get_archiver();-- wal空间占用createter view dba.walsize as select pg_size_pretty(sum(size)) from pg_ls_waldir();-- 复制槽状态(复制槽是否未使用, 可能导致wal日志目录飙升(未清理)create view dba.repslots as select * from pg_replication_slots ;-- 强制保留wal大小的createeeteater view dba.wal_keep_size aswith a as (select setting from pg_settings where name='wal_keep_segments') , b as (select setting,unit from pg_settings where name='wal_segment_size') select pg_size_pretty(a.setting::int8*b.setting::int8) from a,b;-- 最大的wal保留了系统动态检查点的大小 view dba.max_wal_size asselect setting|| ||unit from pg_settings where name='max_wal_size';  -- 长事务、prepared statementcreate view dba.long_snapshot as with a as (select min(transaction::Text::int8) m from pg_prepared_xacts ),b as (select txid_snapshot_xmin(txid_current_snapshot())::text::int8 as m),c as (select min(least(backend_xid::text::int8,backend_xmin::text::int8)) m from pg_stat_activity ),d as (select datname,usename,pid,query_start,xact_start,now(),wait_event,query from pg_stat_activity where backend_xid is not null or backend_xmin is not nullorder by least(backend_xid::text::int8,backend_xmin::text::int8) limit 1),e as (select * from pg_prepared_xacts order by transaction::Text::int8 limit 1)select b.m-least(a.m,c.m),d.*,e.* from a,b,c,d left join e on (1=1);

常用查询

1、查询只读节点延迟

-- 在主节点查询selectt * from dba.ro_delay;  -- 在只读节点查询sett lock_timeout='10ms';set statement_timeout='2s';select * from dba.node_delay;select * from dba.ro_delay_on_standby;

2、查询top query, 优化之首

select * from dba.topsql;

3、重置top query统计计数器(通常可在峰值到来之前重置,以防止结果干扰)

select pg_stat_statements_reset();

4、查询 qps , 在psql 终端可以每秒打印一次

select * from dba.qps;    \watch 1

4.1、查询tps

call dba.tps();

5、查询活跃会话数, 若超过CPU核数, 说明数据库非常非常繁忙, 优化需要注意

select * from dba.session_acting_cnt;

6、当前活跃会话

select * from dba.sessions;

7、查询锁等待, 假如有大量的长时间等待, 业务逻辑是否有问题需要注意

select * from dba.locks;

8、查询占用空间top 10的表

select * from dba.10sizetable;

9、查询占用空间top 10的索引

select * from dba.top10sizindex;

10、查询占用空间top 10表(含索引)

select * from dba.10sizetableindextop;

11、查询膨胀空间top 10的表

select * from dba.top10bloatsizetable;

12、查询膨胀空间top 10的索引

select * from dba.10bloatsizeindextop;

13、查询膨胀比例top 10的表

select * from dba.top10bloatratiotable;

14、查询膨胀比例top 10的索引

select * from dba.10bloatratioindextop;

15、查询、更新和删除记录条数top 10的表

select * from dba.top10updatetable;

16、查询插入记录条数top数 10的表

select * from dba.tabletttop10inserttatter;

17、查询脏记录条数top 10的表

select * from dba.top10deadtabletttable;

18、查询年龄top 10的表

select * from dba.top10age;

19、从当前时间和当前事务数量查询当前最老的事务, 说明膨胀空间的大小, 越有可能导致更多的膨胀垃圾.

select * from dba.oldestxact;  select * from pg_prepared_xacts;

20、查询序列的剩余空间

select * from dba.seqs;

21、PostgreSQL 谁堵了谁(锁等检测)- pg_blocking_pids

《PostgreSQL 谁堵了谁(锁等待检测)- pg_blocking_pids》

22、未使用的索引大于1MB top 10 (注意, PK、如果UK只用于约束, 可能不会被统计数,但不能删除)

select * from dba.10notusedidxtop;

23、查询未使用的大于1MB的表 top 10

select * from dba.10notusedtabtop;

24、查询热表top 10

select * from dba.10hottabtop10;

25、冷表top查询大于1MB 10

select * from dba.top10coldtabttatttabtttop;

26、查询热索引top 10

select * from dba.10hotidxtop;

27、冷索引top,查询大于1MB 10(注意, PK、如果UK只用于约束, 可能不会被统计数,但不能删除)

select * from dba.top10coldidxttop;

28、查询数据库frez风暴预测

select * from dba.v_freeze;select * from dba.v_freeze_stat;select * from dba.v_freeze_stat_detail;

查询top 大表大freeze剩余年龄20。

select * from dba.top20frezebigtable;  -- 结合dba.tps, 可通过remain__ages_xid/dba.tps估计每个表还会发生多久?.call dba.tps();

29、查询RO节点阅读与Replay的冲突次数, 建议Ro节点在高频恢复中不要跑长sql。

select * from  dba.ro_conflicts;

30、DBA在RO 在节点人工执行SQL之前, 建议设置sql超时, 避免长时间跑步 SQL, 导致不必要的replay延迟和 conflict cancel statement

set statement_timeout ='1s';set lock_timeout='10ms';

31、RO 节点的conflict容忍时间最长, 默认为5 min

show max_standby_streaming_delay ; max_standby_streaming_delay ----------------------------- 5min(1 row)

32、清理数据库stat计数器

\df *.*reset*                                              List of functions   Schema   |                  Name                  |     Result data type     | Argument data types | Type ------------+----------------------------------------+--------------------------+---------------------+------ pg_catalog | pg_replication_origin_session_reset    | void                     |                     | func pg_catalog | pg_replication_origin_xact_reset       | void                     |                     | func pg_catalog | pg_stat_get_bgwriter_stat_reset_time   | timestamp with time zone |                     | func pg_catalog | pg_stat_get_db_stat_reset_time         | timestamp with time zone | oid                 | func pg_catalog | pg_stat_reset                          | void                     |                     | func pg_catalog | pg_stat_reset_shared                   | void                     | text                | func pg_catalog | pg_stat_reset_single_function_counters | void                     | oid                 | func pg_catalog | pg_stat_reset_single_table_counters    | void                     | oid                 | func public     | pg_stat_statements_reset               | void                     |                     | func(9 rows)

33、在standby节点执行, 检查当前standby节点接收wal的速度

call dba.wal_receive_bw();

34、在standby节点执行, 检查当前standby节点replay wal的速度

call dba.wal_replay_bw();

35、使用wal文件,查看slot风险。

select * from dba.arch_undone;select * from dba.arch_status;select * from dba.walsize;select * from dba.repslots;select * from dba.wal_keep_size;select * from dba.max_wal_size;

36、长事务、prepared statement

select * from dba.long_snapshot;

37、查询无效索引。

select * from dba.invalid_index;

参考

《PostgreSQL 实时健康监测 大屏 - 低频指标 - 珍藏级》

《PostgreSQL 实时健康监测 大屏 - 高频指标(服务器) - 珍藏级》

《PostgreSQL 实时健康监测 大屏 - 高频指标 - 珍藏级》

《PostgreSQL Freeze 风暴预测续 - 收藏级SQL

作者digoal

作者:古道轻风,