james/pgmon
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 3 Wiki Activity

Remove some type casts from working around Decimal types

Browse Source
This commit is contained in:
James Campbell 2025-07-03 10:16:20 -04:00
parent 6116f4f885
commit 45953848e2
Signed by: james
GPG Key ID: 2287C33A40DC906A
1 changed files with 28 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
sample-config/pgmon-metrics.yml
View File

@ -98,20 +98,20 @@ metrics:
query: query:
160000: > 160000: >
SELECT backend_type, SELECT backend_type,
COALESCE(SUM(reads * op_bytes), 0)::bigint AS reads, COALESCE(SUM(reads * op_bytes), 0) AS reads,
COALESCE(SUM(read_time), 0)::bigint AS read_time, COALESCE(SUM(read_time), 0) AS read_time,
COALESCE(SUM(writes * op_bytes), 0)::bigint AS writes, COALESCE(SUM(writes * op_bytes), 0) AS writes,
COALESCE(SUM(write_time), 0)::bigint AS write_time, COALESCE(SUM(write_time), 0) AS write_time,
COALESCE(SUM(writebacks * op_bytes), 0)::bigint AS writebacks, COALESCE(SUM(writebacks * op_bytes), 0) AS writebacks,
COALESCE(SUM(writeback_time), 0)::bigint AS writeback_time, COALESCE(SUM(writeback_time), 0) AS writeback_time,
COALESCE(SUM(extends * op_bytes), 0)::bigint AS extends, COALESCE(SUM(extends * op_bytes), 0) AS extends,
COALESCE(SUM(extend_time), 0)::bigint AS extend_time, COALESCE(SUM(extend_time), 0) AS extend_time,
COALESCE(SUM(op_bytes), 0)::bigint AS op_bytes, COALESCE(SUM(op_bytes), 0) AS op_bytes,
COALESCE(SUM(hits), 0)::bigint AS hits, COALESCE(SUM(hits), 0) AS hits,
COALESCE(SUM(evictions), 0)::bigint AS evictions, COALESCE(SUM(evictions), 0) AS evictions,
COALESCE(SUM(reuses), 0)::bigint AS reuses, COALESCE(SUM(reuses), 0) AS reuses,
COALESCE(SUM(fsyncs), 0)::bigint AS fsyncs, COALESCE(SUM(fsyncs), 0) AS fsyncs,
COALESCE(SUM(fsync_time), 0)::bigint AS fsync_time COALESCE(SUM(fsync_time), 0) AS fsync_time
FROM pg_stat_io FROM pg_stat_io
GROUP BY backend_type GROUP BY backend_type
@ -147,7 +147,7 @@ metrics:
NULL AS sessions_abandoned, NULL AS sessions_abandoned,
NULL AS sessions_fatal, NULL AS sessions_fatal,
NULL AS sessions_killed, NULL AS sessions_killed,
extract('epoch' from stats_reset)::float AS stats_reset extract('epoch' from stats_reset) AS stats_reset
FROM pg_stat_database WHERE datname = %(dbname)s FROM pg_stat_database WHERE datname = %(dbname)s
140000: > 140000: >
SELECT numbackends, SELECT numbackends,
@ -174,7 +174,7 @@ metrics:
sessions_abandoned, sessions_abandoned,
sessions_fatal, sessions_fatal,
sessions_killed, sessions_killed,
extract('epoch' from stats_reset)::float AS stats_reset extract('epoch' from stats_reset) AS stats_reset
FROM pg_stat_database WHERE datname = %(dbname)s FROM pg_stat_database WHERE datname = %(dbname)s
test_args: test_args:
dbname: postgres dbname: postgres
@ -197,7 +197,7 @@ metrics:
0: > 0: >
SELECT state, SELECT state,
count(*) AS backend_count, count(*) AS backend_count,
COALESCE(EXTRACT(EPOCH FROM max(now() - state_change))::float, 0) AS max_state_time COALESCE(EXTRACT(EPOCH FROM max(now() - state_change)) 0) AS max_state_time
FROM pg_stat_activity FROM pg_stat_activity
WHERE datname = %(dbname)s WHERE datname = %(dbname)s
GROUP BY state GROUP BY state
@ -226,7 +226,7 @@ metrics:
type: row type: row
query: query:
100000: > 100000: >
SELECT COUNT(*) FILTER (WHERE has_sequence_privilege(c.oid, 'SELECT,USAGE'::text)) AS readable_sequences, SELECT COUNT(*) FILTER (WHERE has_sequence_privilege(c.oid, 'SELECT,USAGE')) AS readable_sequences,
COUNT(*) AS total_sequences COUNT(*) AS total_sequences
FROM pg_class AS c FROM pg_class AS c
WHERE relkind = 'S'; WHERE relkind = 'S';
@ -240,7 +240,7 @@ metrics:
query: query:
90400: > 90400: >
SELECT pid, usename, SELECT pid, usename,
EXTRACT(EPOCH FROM backend_start)::integer AS backend_start, EXTRACT(EPOCH FROM backend_start) AS backend_start,
state, state,
pg_xlog_location_diff(pg_current_xlog_location(), sent_location) AS sent_lsn, pg_xlog_location_diff(pg_current_xlog_location(), sent_location) AS sent_lsn,
pg_xlog_location_diff(pg_current_xlog_location(), write_location) AS write_lsn, pg_xlog_location_diff(pg_current_xlog_location(), write_location) AS write_lsn,
@ -254,15 +254,15 @@ metrics:
WHERE host(client_addr) || '_' || regexp_replace(application_name, '[ ,]', '_', 'g') = %(repid)s WHERE host(client_addr) || '_' || regexp_replace(application_name, '[ ,]', '_', 'g') = %(repid)s
100000: > 100000: >
SELECT pid, usename, SELECT pid, usename,
EXTRACT(EPOCH FROM backend_start)::integer AS backend_start, EXTRACT(EPOCH FROM backend_start) AS backend_start,
state, state,
pg_wal_lsn_diff(pg_current_wal_lsn(), sent_lsn) AS sent_lsn, pg_wal_lsn_diff(pg_current_wal_lsn(), sent_lsn) AS sent_lsn,
pg_wal_lsn_diff(pg_current_wal_lsn(), write_lsn) AS write_lsn, pg_wal_lsn_diff(pg_current_wal_lsn(), write_lsn) AS write_lsn,
pg_wal_lsn_diff(pg_current_wal_lsn(), flush_lsn) AS flush_lsn, pg_wal_lsn_diff(pg_current_wal_lsn(), flush_lsn) AS flush_lsn,
pg_wal_lsn_diff(pg_current_wal_lsn(), replay_lsn) AS replay_lsn, pg_wal_lsn_diff(pg_current_wal_lsn(), replay_lsn) AS replay_lsn,
COALESCE(EXTRACT(EPOCH FROM write_lag), 0)::integer AS write_lag, COALESCE(EXTRACT(EPOCH FROM write_lag), 0) AS write_lag,
COALESCE(EXTRACT(EPOCH FROM flush_lag), 0)::integer AS flush_lag, COALESCE(EXTRACT(EPOCH FROM flush_lag), 0) AS flush_lag,
COALESCE(EXTRACT(EPOCH FROM replay_lag), 0)::integer AS replay_lag, COALESCE(EXTRACT(EPOCH FROM replay_lag), 0) AS replay_lag,
sync_state sync_state
FROM pg_stat_replication FROM pg_stat_replication
WHERE host(client_addr) || '_' || regexp_replace(application_name, '[ ,]', '_', 'g') = %(repid)s WHERE host(client_addr) || '_' || regexp_replace(application_name, '[ ,]', '_', 'g') = %(repid)s
@ -279,20 +279,20 @@ metrics:
90400: > 90400: >
SELECT NULL as active_pid, SELECT NULL as active_pid,
xmin, xmin,
pg_xlog_location_diff(pg_current_xlog_location(), restart_lsn)::bigint AS restart_bytes, pg_xlog_location_diff(pg_current_xlog_location(), restart_lsn) AS restart_bytes,
NULL AS confirmed_flush_bytes NULL AS confirmed_flush_bytes
FROM pg_replication_slots WHERE slot_name = %(slot)s FROM pg_replication_slots WHERE slot_name = %(slot)s
90600: > 90600: >
SELECT active_pid, SELECT active_pid,
xmin, xmin,
pg_xlog_location_diff(pg_current_xlog_location(), restart_lsn)::bigint AS restart_bytes, pg_xlog_location_diff(pg_current_xlog_location(), restart_lsn) AS restart_bytes,
pg_xlog_location_diff(pg_current_xlog_location(), confirmed_flush_lsn)::bigint AS confirmed_flush_bytes pg_xlog_location_diff(pg_current_xlog_location(), confirmed_flush_lsn) AS confirmed_flush_bytes
FROM pg_replication_slots WHERE slot_name = %(slot)s FROM pg_replication_slots WHERE slot_name = %(slot)s
100000: > 100000: >
SELECT active_pid, SELECT active_pid,
xmin, xmin,
pg_wal_lsn_diff(pg_current_wal_lsn(), restart_lsn)::bigint AS restart_bytes, pg_wal_lsn_diff(pg_current_wal_lsn(), restart_lsn) AS restart_bytes,
pg_wal_lsn_diff(pg_current_wal_lsn(), confirmed_flush_lsn)::bigint AS confirmed_flush_bytes pg_wal_lsn_diff(pg_current_wal_lsn(), confirmed_flush_lsn) AS confirmed_flush_bytes
FROM pg_replication_slots WHERE slot_name = %(slot)s FROM pg_replication_slots WHERE slot_name = %(slot)s
test_args: test_args:
slot: test_slot slot: test_slot