Zapytania do monitoringu

Sloty (debezium)

SELECT slot_name, active, case when redo_lsn - restart_lsn > 0 then redo_lsn - restart_lsn else 0 end AS lag_in_b, extract(epoch from replay_lag) as lag_in_s FROM pg_control_checkpoint(), pg_replication_slots s left join pg_stat_replication r on s.active_pid = r.pid

slot_name - nazwa slotu
active - t/f, czy slot jest aktywny, f = DISASTER
lag_in_b - lag w bajtach
lag_in_s - lag w sekundach

Z uwagi na to, że debezium co minutę pobiera zmiany, lag_in_s < 60 nie jest powodem do jakiegokolwiek niepokoju

Uszkodzone indeksy

select indexrelid::regclass, indrelid::regclass from pg_index where indisvalid = false;

Lista indeksów które wymagają reindex.

Bloat

Aby nie puszczać Vacuum na całej bazie można puścić to na konkretnym obiekcie, ale skąd wiedzieć na którym? Łączymy się z nasza bazą danych i puszczamy takie query:

with first as (
  SELECT
    schemaname, tablename, hdr, ma, bs,
    SUM((1-null_frac)avg_width) AS datawidth,
    MAX(null_frac) AS maxfracsum,
    hdr+(
      SELECT 1+COUNT()/8
      FROM pg_stats s2
      WHERE null_frac<>0 AND s2.schemaname = s.schemaname AND s2.tablename = s.tablename
    ) AS nullhdr
  FROM pg_stats s, (
    SELECT
      (SELECT current_setting('block_size')::NUMERIC) AS bs,
      CASE WHEN SUBSTRING(v,12,3) IN ('8.0','8.1','8.2') THEN 27 ELSE 23 END AS hdr,
      CASE WHEN v ~ 'mingw32' THEN 8 ELSE 4 END AS ma
    FROM (SELECT version() AS v) AS foo
  ) AS constants
  GROUP BY 1,2,3,4,5
), second as (
  SELECT
    ma,bs,schemaname,tablename,
    (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 first
), third as (
  SELECT
    schemaname, tablename, cc.reltuples, cc.relpages, bs,
    CEIL((cc.reltuples*((datahdr+ma-
      (CASE WHEN datahdr%ma=0 THEN ma ELSE datahdr%ma END))+nullhdr2+4))/(bs-20::FLOAT)) 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 second
  JOIN pg_class cc ON cc.relname = second.tablename
  JOIN pg_namespace nn ON cc.relnamespace = nn.oid AND nn.nspname = second.schemaname AND nn.nspname <> 'information_schema'
  LEFT JOIN pg_index i ON indrelid = cc.oid
  LEFT JOIN pg_class c2 ON c2.oid = i.indexrelid
)

SELECT
  current_database(), schemaname, tablename, /reltuples::bigint, relpages::bigint, otta,/
  ROUND((CASE WHEN otta=0 THEN 0.0 ELSE third.relpages::FLOAT/otta END)::NUMERIC,1) AS tbloat,
  CASE WHEN relpages < otta THEN 0 ELSE bs*(third.relpages-otta)::BIGINT END AS wastedbytes,
  iname, /ituples::bigint, ipages::bigint, iotta,/
  ROUND((CASE WHEN iotta=0 OR ipages=0 THEN 0.0 ELSE ipages::FLOAT/iotta END)::NUMERIC,1) AS ibloat,
  CASE WHEN ipages < iotta THEN 0 ELSE bs*(ipages-iotta) END AS wastedibytes
FROM third
ORDER BY wastedbytes DESC;

Jak często zamierzacie puszczać tego selecta to można ułatwić sobie życie i na podstawie powyższego query stworzyć widok :slight_smile:

No dobra - co mówi nam ten widok?

Pierwsze 3 kolumny mówią same za siebie;

tbloat - współczynnik dla tabeli określający czym jest obecnie a czym mogłoby być;

wastebytes - ilość zmarnowanych bajtów dla tabeli;

iname - nazwa indeksu (o vacuum i indeksach później napiszę)

ibloat - współczynnik dla indeksu określający czym jest obecnie a czym mogłoby być;

wastedibytes - ilość zmarnowanych bajtów dla indeksu;

czyli: im większa wartość pola i/tbloat i wasted[i]bytes to tym bardziej powinnismy się zainteresować takim obiektem :slight_smile:

Last modified: 30 May 2024