With slots_info AS ( SELECT slot.slot_name, slot.active, slot.slot_type, stat.write_lsn, stat.flush_lsn, stat.sync_state, slot.restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END as wal_retention_from_restart_lsn, stat.replay_lsn, CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END as replay_lsn_else_restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name ( CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END) END as must_retain_wal_file, CASE WHEN pg_is_in_recovery() THEN NULL ELSE ( CASE WHEN stat.replay_lsn IS NULL THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END) END as wal_retention_from_replay_lsn FROM pg_catalog.pg_replication_slots slot LEFT JOIN pg_catalog.pg_stat_replication stat ON slot.active_pid = stat.pid ), standby_and_walreplica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name LIKE 'azure_standby%' or slot_name like 'wal_replica%' ), read_replica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name not LIKE 'azure_standby%' and slot_name not like 'wal_replica%' ) SELECT ( SELECT row_to_json(t1) logical_slots FROM ( SELECT ( SELECT count(*) as active FROM slots_info where slot_type = 'logical' and active = true), ( SELECT count(*) as inactive FROM slots_info where slot_type = 'logical' and active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM slots_info where slot_type = 'logical' order by replay_lsn_else_restart_lsn) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) read_replica_slots FROM ( SELECT ( SELECT count(*) as active FROM read_replica_slot_info where active = true), ( SELECT count(*) as inactive FROM read_replica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM read_replica_slot_info order by replay_lsn_else_restart_lsn limit 4) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) standby_and_walreplica_slots FROM ( SELECT ( SELECT count(*) as active FROM standby_and_walreplica_slot_info where active = true), ( SELECT count(*) as inactive FROM standby_and_walreplica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM standby_and_walreplica_slot_info) as t) as lagging_order) as t1), ( Select row_to_json(t)::text as checkpoint_info FROM ( Select ( SELECT trunc(MAX(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - xact_start))) AS max_age FROM pg_stat_activity) oldest_live_tx_age, trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - checkpoint_time)) as seconds_after_last_checkpoint, timeline_id, checkpoint_lsn, TO_CHAR(checkpoint_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as checkpoint_time, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (checkpoint_lsn) END AS checkpoint_wal_file, redo_lsn, redo_wal_file, buffers_alloc, block_size, now() - stats_reset stats_reset from pg_catalog.pg_control_checkpoint (), pg_stat_bgwriter, ( SELECT cast(current_setting('block_size') AS integer) AS block_size) as sub_query) as t), ( Select row_to_json(t)::text as archiver_info FROM ( Select trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - last_archived_time)) last_archival, (last_failed_wal IS NULL OR last_failed_wal <= last_archived_wal) is_archiving, trunc( CASE WHEN archived_count = 0 OR EXTRACT(EPOCH FROM age(now(), stats_reset)) = 0 THEN 0 ELSE CAST(archived_count AS numeric) * 60 / EXTRACT(EPOCH FROM age(now(), stats_reset)) END) wals_archived_per_minute, last_archived_wal, TO_CHAR(last_archived_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as last_archived_time, last_failed_wal, archived_count, failed_count, now() - stats_reset as stats_reset from pg_catalog.pg_stat_archiver) as t), ( Select row_to_json(t)::text as wal_upload_related_details FROM ( SELECT ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (pg_catalog.pg_current_wal_lsn ()) END as current), ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (flush_lsn) END as quorum_committed FROM slots_info where slot_type = 'physical' and sync_state = 'quorum' order by flush_lsn desc limit 1), ( SELECT CAST(pg_catalog.current_setting('azure.enforce_ha_quorom') AS boolean) AS enforce_ha_quorom), ( SELECT pg_catalog.current_setting('synchronous_standby_names') AS synchronous_standby_names), ( SELECT CAST(pg_catalog.pg_is_in_recovery() AS boolean) AS pg_is_in_recovery)) as t), ( select TO_CHAR(pg_catalog.now() at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS')) as time_fetched;

[ Date: 2025-10-10 19:37:58 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] - Bind query: yes ]

With slots_info AS ( SELECT slot.slot_name, slot.active, slot.slot_type, stat.write_lsn, stat.flush_lsn, stat.sync_state, slot.restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END as wal_retention_from_restart_lsn, stat.replay_lsn, CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END as replay_lsn_else_restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name ( CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END) END as must_retain_wal_file, CASE WHEN pg_is_in_recovery() THEN NULL ELSE ( CASE WHEN stat.replay_lsn IS NULL THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END) END as wal_retention_from_replay_lsn FROM pg_catalog.pg_replication_slots slot LEFT JOIN pg_catalog.pg_stat_replication stat ON slot.active_pid = stat.pid ), standby_and_walreplica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name LIKE 'azure_standby%' or slot_name like 'wal_replica%' ), read_replica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name not LIKE 'azure_standby%' and slot_name not like 'wal_replica%' ) SELECT ( SELECT row_to_json(t1) logical_slots FROM ( SELECT ( SELECT count(*) as active FROM slots_info where slot_type = 'logical' and active = true), ( SELECT count(*) as inactive FROM slots_info where slot_type = 'logical' and active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM slots_info where slot_type = 'logical' order by replay_lsn_else_restart_lsn) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) read_replica_slots FROM ( SELECT ( SELECT count(*) as active FROM read_replica_slot_info where active = true), ( SELECT count(*) as inactive FROM read_replica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM read_replica_slot_info order by replay_lsn_else_restart_lsn limit 4) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) standby_and_walreplica_slots FROM ( SELECT ( SELECT count(*) as active FROM standby_and_walreplica_slot_info where active = true), ( SELECT count(*) as inactive FROM standby_and_walreplica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM standby_and_walreplica_slot_info) as t) as lagging_order) as t1), ( Select row_to_json(t)::text as checkpoint_info FROM ( Select ( SELECT trunc(MAX(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - xact_start))) AS max_age FROM pg_stat_activity) oldest_live_tx_age, trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - checkpoint_time)) as seconds_after_last_checkpoint, timeline_id, checkpoint_lsn, TO_CHAR(checkpoint_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as checkpoint_time, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (checkpoint_lsn) END AS checkpoint_wal_file, redo_lsn, redo_wal_file, buffers_alloc, block_size, now() - stats_reset stats_reset from pg_catalog.pg_control_checkpoint (), pg_stat_bgwriter, ( SELECT cast(current_setting('block_size') AS integer) AS block_size) as sub_query) as t), ( Select row_to_json(t)::text as archiver_info FROM ( Select trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - last_archived_time)) last_archival, (last_failed_wal IS NULL OR last_failed_wal <= last_archived_wal) is_archiving, trunc( CASE WHEN archived_count = 0 OR EXTRACT(EPOCH FROM age(now(), stats_reset)) = 0 THEN 0 ELSE CAST(archived_count AS numeric) * 60 / EXTRACT(EPOCH FROM age(now(), stats_reset)) END) wals_archived_per_minute, last_archived_wal, TO_CHAR(last_archived_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as last_archived_time, last_failed_wal, archived_count, failed_count, now() - stats_reset as stats_reset from pg_catalog.pg_stat_archiver) as t), ( Select row_to_json(t)::text as wal_upload_related_details FROM ( SELECT ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (pg_catalog.pg_current_wal_lsn ()) END as current), ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (flush_lsn) END as quorum_committed FROM slots_info where slot_type = 'physical' and sync_state = 'quorum' order by flush_lsn desc limit 1), ( SELECT CAST(pg_catalog.current_setting('azure.enforce_ha_quorom') AS boolean) AS enforce_ha_quorom), ( SELECT pg_catalog.current_setting('synchronous_standby_names') AS synchronous_standby_names), ( SELECT CAST(pg_catalog.pg_is_in_recovery() AS boolean) AS pg_is_in_recovery)) as t), ( select TO_CHAR(pg_catalog.now() at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS')) as time_fetched;

[ Date: 2025-10-10 12:01:02 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] - Bind query: yes ]

With slots_info AS ( SELECT slot.slot_name, slot.active, slot.slot_type, stat.write_lsn, stat.flush_lsn, stat.sync_state, slot.restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END as wal_retention_from_restart_lsn, stat.replay_lsn, CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END as replay_lsn_else_restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name ( CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END) END as must_retain_wal_file, CASE WHEN pg_is_in_recovery() THEN NULL ELSE ( CASE WHEN stat.replay_lsn IS NULL THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END) END as wal_retention_from_replay_lsn FROM pg_catalog.pg_replication_slots slot LEFT JOIN pg_catalog.pg_stat_replication stat ON slot.active_pid = stat.pid ), standby_and_walreplica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name LIKE 'azure_standby%' or slot_name like 'wal_replica%' ), read_replica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name not LIKE 'azure_standby%' and slot_name not like 'wal_replica%' ) SELECT ( SELECT row_to_json(t1) logical_slots FROM ( SELECT ( SELECT count(*) as active FROM slots_info where slot_type = 'logical' and active = true), ( SELECT count(*) as inactive FROM slots_info where slot_type = 'logical' and active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM slots_info where slot_type = 'logical' order by replay_lsn_else_restart_lsn) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) read_replica_slots FROM ( SELECT ( SELECT count(*) as active FROM read_replica_slot_info where active = true), ( SELECT count(*) as inactive FROM read_replica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM read_replica_slot_info order by replay_lsn_else_restart_lsn limit 4) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) standby_and_walreplica_slots FROM ( SELECT ( SELECT count(*) as active FROM standby_and_walreplica_slot_info where active = true), ( SELECT count(*) as inactive FROM standby_and_walreplica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM standby_and_walreplica_slot_info) as t) as lagging_order) as t1), ( Select row_to_json(t)::text as checkpoint_info FROM ( Select ( SELECT trunc(MAX(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - xact_start))) AS max_age FROM pg_stat_activity) oldest_live_tx_age, trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - checkpoint_time)) as seconds_after_last_checkpoint, timeline_id, checkpoint_lsn, TO_CHAR(checkpoint_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as checkpoint_time, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (checkpoint_lsn) END AS checkpoint_wal_file, redo_lsn, redo_wal_file, buffers_alloc, block_size, now() - stats_reset stats_reset from pg_catalog.pg_control_checkpoint (), pg_stat_bgwriter, ( SELECT cast(current_setting('block_size') AS integer) AS block_size) as sub_query) as t), ( Select row_to_json(t)::text as archiver_info FROM ( Select trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - last_archived_time)) last_archival, (last_failed_wal IS NULL OR last_failed_wal <= last_archived_wal) is_archiving, trunc( CASE WHEN archived_count = 0 OR EXTRACT(EPOCH FROM age(now(), stats_reset)) = 0 THEN 0 ELSE CAST(archived_count AS numeric) * 60 / EXTRACT(EPOCH FROM age(now(), stats_reset)) END) wals_archived_per_minute, last_archived_wal, TO_CHAR(last_archived_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as last_archived_time, last_failed_wal, archived_count, failed_count, now() - stats_reset as stats_reset from pg_catalog.pg_stat_archiver) as t), ( Select row_to_json(t)::text as wal_upload_related_details FROM ( SELECT ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (pg_catalog.pg_current_wal_lsn ()) END as current), ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (flush_lsn) END as quorum_committed FROM slots_info where slot_type = 'physical' and sync_state = 'quorum' order by flush_lsn desc limit 1), ( SELECT CAST(pg_catalog.current_setting('azure.enforce_ha_quorom') AS boolean) AS enforce_ha_quorom), ( SELECT pg_catalog.current_setting('synchronous_standby_names') AS synchronous_standby_names), ( SELECT CAST(pg_catalog.pg_is_in_recovery() AS boolean) AS pg_is_in_recovery)) as t), ( select TO_CHAR(pg_catalog.now() at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS')) as time_fetched;

[ Date: 2025-10-10 10:32:08 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] - Bind query: yes ]

SELECT setting FROM pg_catalog.pg_settings where name = 'pg_qs.emit_logs_for_instance_types';

[ Date: 2025-10-10 14:28:10 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] - Bind query: yes ]

With slots_info AS ( SELECT slot.slot_name, slot.active, slot.slot_type, stat.write_lsn, stat.flush_lsn, stat.sync_state, slot.restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END as wal_retention_from_restart_lsn, stat.replay_lsn, CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END as replay_lsn_else_restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name ( CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END) END as must_retain_wal_file, CASE WHEN pg_is_in_recovery() THEN NULL ELSE ( CASE WHEN stat.replay_lsn IS NULL THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END) END as wal_retention_from_replay_lsn FROM pg_catalog.pg_replication_slots slot LEFT JOIN pg_catalog.pg_stat_replication stat ON slot.active_pid = stat.pid ), standby_and_walreplica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name LIKE 'azure_standby%' or slot_name like 'wal_replica%' ), read_replica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name not LIKE 'azure_standby%' and slot_name not like 'wal_replica%' ) SELECT ( SELECT row_to_json(t1) logical_slots FROM ( SELECT ( SELECT count(*) as active FROM slots_info where slot_type = 'logical' and active = true), ( SELECT count(*) as inactive FROM slots_info where slot_type = 'logical' and active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM slots_info where slot_type = 'logical' order by replay_lsn_else_restart_lsn) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) read_replica_slots FROM ( SELECT ( SELECT count(*) as active FROM read_replica_slot_info where active = true), ( SELECT count(*) as inactive FROM read_replica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM read_replica_slot_info order by replay_lsn_else_restart_lsn limit 4) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) standby_and_walreplica_slots FROM ( SELECT ( SELECT count(*) as active FROM standby_and_walreplica_slot_info where active = true), ( SELECT count(*) as inactive FROM standby_and_walreplica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM standby_and_walreplica_slot_info) as t) as lagging_order) as t1), ( Select row_to_json(t)::text as checkpoint_info FROM ( Select ( SELECT trunc(MAX(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - xact_start))) AS max_age FROM pg_stat_activity) oldest_live_tx_age, trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - checkpoint_time)) as seconds_after_last_checkpoint, timeline_id, checkpoint_lsn, TO_CHAR(checkpoint_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as checkpoint_time, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (checkpoint_lsn) END AS checkpoint_wal_file, redo_lsn, redo_wal_file, buffers_alloc, block_size, now() - stats_reset stats_reset from pg_catalog.pg_control_checkpoint (), pg_stat_bgwriter, ( SELECT cast(current_setting('block_size') AS integer) AS block_size) as sub_query) as t), ( Select row_to_json(t)::text as archiver_info FROM ( Select trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - last_archived_time)) last_archival, (last_failed_wal IS NULL OR last_failed_wal <= last_archived_wal) is_archiving, trunc( CASE WHEN archived_count = 0 OR EXTRACT(EPOCH FROM age(now(), stats_reset)) = 0 THEN 0 ELSE CAST(archived_count AS numeric) * 60 / EXTRACT(EPOCH FROM age(now(), stats_reset)) END) wals_archived_per_minute, last_archived_wal, TO_CHAR(last_archived_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as last_archived_time, last_failed_wal, archived_count, failed_count, now() - stats_reset as stats_reset from pg_catalog.pg_stat_archiver) as t), ( Select row_to_json(t)::text as wal_upload_related_details FROM ( SELECT ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (pg_catalog.pg_current_wal_lsn ()) END as current), ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (flush_lsn) END as quorum_committed FROM slots_info where slot_type = 'physical' and sync_state = 'quorum' order by flush_lsn desc limit 1), ( SELECT CAST(pg_catalog.current_setting('azure.enforce_ha_quorom') AS boolean) AS enforce_ha_quorom), ( SELECT pg_catalog.current_setting('synchronous_standby_names') AS synchronous_standby_names), ( SELECT CAST(pg_catalog.pg_is_in_recovery() AS boolean) AS pg_is_in_recovery)) as t), ( select TO_CHAR(pg_catalog.now() at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS')) as time_fetched;

[ Date: 2025-10-10 13:04:06 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] - Bind query: yes ]

SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (public.pg_last_removed_wal_lsn ()) END as pg_walfile_name;

[ Date: 2025-10-10 18:24:34 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] - Bind query: yes ]

With slots_info AS ( SELECT slot.slot_name, slot.active, slot.slot_type, stat.write_lsn, stat.flush_lsn, stat.sync_state, slot.restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END as wal_retention_from_restart_lsn, stat.replay_lsn, CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END as replay_lsn_else_restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name ( CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END) END as must_retain_wal_file, CASE WHEN pg_is_in_recovery() THEN NULL ELSE ( CASE WHEN stat.replay_lsn IS NULL THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END) END as wal_retention_from_replay_lsn FROM pg_catalog.pg_replication_slots slot LEFT JOIN pg_catalog.pg_stat_replication stat ON slot.active_pid = stat.pid ), standby_and_walreplica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name LIKE 'azure_standby%' or slot_name like 'wal_replica%' ), read_replica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name not LIKE 'azure_standby%' and slot_name not like 'wal_replica%' ) SELECT ( SELECT row_to_json(t1) logical_slots FROM ( SELECT ( SELECT count(*) as active FROM slots_info where slot_type = 'logical' and active = true), ( SELECT count(*) as inactive FROM slots_info where slot_type = 'logical' and active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM slots_info where slot_type = 'logical' order by replay_lsn_else_restart_lsn) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) read_replica_slots FROM ( SELECT ( SELECT count(*) as active FROM read_replica_slot_info where active = true), ( SELECT count(*) as inactive FROM read_replica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM read_replica_slot_info order by replay_lsn_else_restart_lsn limit 4) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) standby_and_walreplica_slots FROM ( SELECT ( SELECT count(*) as active FROM standby_and_walreplica_slot_info where active = true), ( SELECT count(*) as inactive FROM standby_and_walreplica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM standby_and_walreplica_slot_info) as t) as lagging_order) as t1), ( Select row_to_json(t)::text as checkpoint_info FROM ( Select ( SELECT trunc(MAX(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - xact_start))) AS max_age FROM pg_stat_activity) oldest_live_tx_age, trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - checkpoint_time)) as seconds_after_last_checkpoint, timeline_id, checkpoint_lsn, TO_CHAR(checkpoint_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as checkpoint_time, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (checkpoint_lsn) END AS checkpoint_wal_file, redo_lsn, redo_wal_file, buffers_alloc, block_size, now() - stats_reset stats_reset from pg_catalog.pg_control_checkpoint (), pg_stat_bgwriter, ( SELECT cast(current_setting('block_size') AS integer) AS block_size) as sub_query) as t), ( Select row_to_json(t)::text as archiver_info FROM ( Select trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - last_archived_time)) last_archival, (last_failed_wal IS NULL OR last_failed_wal <= last_archived_wal) is_archiving, trunc( CASE WHEN archived_count = 0 OR EXTRACT(EPOCH FROM age(now(), stats_reset)) = 0 THEN 0 ELSE CAST(archived_count AS numeric) * 60 / EXTRACT(EPOCH FROM age(now(), stats_reset)) END) wals_archived_per_minute, last_archived_wal, TO_CHAR(last_archived_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as last_archived_time, last_failed_wal, archived_count, failed_count, now() - stats_reset as stats_reset from pg_catalog.pg_stat_archiver) as t), ( Select row_to_json(t)::text as wal_upload_related_details FROM ( SELECT ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (pg_catalog.pg_current_wal_lsn ()) END as current), ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (flush_lsn) END as quorum_committed FROM slots_info where slot_type = 'physical' and sync_state = 'quorum' order by flush_lsn desc limit 1), ( SELECT CAST(pg_catalog.current_setting('azure.enforce_ha_quorom') AS boolean) AS enforce_ha_quorom), ( SELECT pg_catalog.current_setting('synchronous_standby_names') AS synchronous_standby_names), ( SELECT CAST(pg_catalog.pg_is_in_recovery() AS boolean) AS pg_is_in_recovery)) as t), ( select TO_CHAR(pg_catalog.now() at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS')) as time_fetched;

[ Date: 2025-10-10 23:23:20 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] - Bind query: yes ]

SELECT setting FROM pg_catalog.pg_settings where name = 'pg_qs.emit_logs_for_instance_types';

[ Date: 2025-10-10 06:27:09 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] - Bind query: yes ]

With slots_info AS ( SELECT slot.slot_name, slot.active, slot.slot_type, stat.write_lsn, stat.flush_lsn, stat.sync_state, slot.restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END as wal_retention_from_restart_lsn, stat.replay_lsn, CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END as replay_lsn_else_restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name ( CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END) END as must_retain_wal_file, CASE WHEN pg_is_in_recovery() THEN NULL ELSE ( CASE WHEN stat.replay_lsn IS NULL THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END) END as wal_retention_from_replay_lsn FROM pg_catalog.pg_replication_slots slot LEFT JOIN pg_catalog.pg_stat_replication stat ON slot.active_pid = stat.pid ), standby_and_walreplica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name LIKE 'azure_standby%' or slot_name like 'wal_replica%' ), read_replica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name not LIKE 'azure_standby%' and slot_name not like 'wal_replica%' ) SELECT ( SELECT row_to_json(t1) logical_slots FROM ( SELECT ( SELECT count(*) as active FROM slots_info where slot_type = 'logical' and active = true), ( SELECT count(*) as inactive FROM slots_info where slot_type = 'logical' and active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM slots_info where slot_type = 'logical' order by replay_lsn_else_restart_lsn) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) read_replica_slots FROM ( SELECT ( SELECT count(*) as active FROM read_replica_slot_info where active = true), ( SELECT count(*) as inactive FROM read_replica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM read_replica_slot_info order by replay_lsn_else_restart_lsn limit 4) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) standby_and_walreplica_slots FROM ( SELECT ( SELECT count(*) as active FROM standby_and_walreplica_slot_info where active = true), ( SELECT count(*) as inactive FROM standby_and_walreplica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM standby_and_walreplica_slot_info) as t) as lagging_order) as t1), ( Select row_to_json(t)::text as checkpoint_info FROM ( Select ( SELECT trunc(MAX(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - xact_start))) AS max_age FROM pg_stat_activity) oldest_live_tx_age, trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - checkpoint_time)) as seconds_after_last_checkpoint, timeline_id, checkpoint_lsn, TO_CHAR(checkpoint_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as checkpoint_time, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (checkpoint_lsn) END AS checkpoint_wal_file, redo_lsn, redo_wal_file, buffers_alloc, block_size, now() - stats_reset stats_reset from pg_catalog.pg_control_checkpoint (), pg_stat_bgwriter, ( SELECT cast(current_setting('block_size') AS integer) AS block_size) as sub_query) as t), ( Select row_to_json(t)::text as archiver_info FROM ( Select trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - last_archived_time)) last_archival, (last_failed_wal IS NULL OR last_failed_wal <= last_archived_wal) is_archiving, trunc( CASE WHEN archived_count = 0 OR EXTRACT(EPOCH FROM age(now(), stats_reset)) = 0 THEN 0 ELSE CAST(archived_count AS numeric) * 60 / EXTRACT(EPOCH FROM age(now(), stats_reset)) END) wals_archived_per_minute, last_archived_wal, TO_CHAR(last_archived_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as last_archived_time, last_failed_wal, archived_count, failed_count, now() - stats_reset as stats_reset from pg_catalog.pg_stat_archiver) as t), ( Select row_to_json(t)::text as wal_upload_related_details FROM ( SELECT ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (pg_catalog.pg_current_wal_lsn ()) END as current), ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (flush_lsn) END as quorum_committed FROM slots_info where slot_type = 'physical' and sync_state = 'quorum' order by flush_lsn desc limit 1), ( SELECT CAST(pg_catalog.current_setting('azure.enforce_ha_quorom') AS boolean) AS enforce_ha_quorom), ( SELECT pg_catalog.current_setting('synchronous_standby_names') AS synchronous_standby_names), ( SELECT CAST(pg_catalog.pg_is_in_recovery() AS boolean) AS pg_is_in_recovery)) as t), ( select TO_CHAR(pg_catalog.now() at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS')) as time_fetched;

[ Date: 2025-10-10 09:47:41 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] - Bind query: yes ]

DISCARD ALL;

[ Date: 2025-10-10 12:12:35 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] ]

With slots_info AS ( SELECT slot.slot_name, slot.active, slot.slot_type, stat.write_lsn, stat.flush_lsn, stat.sync_state, slot.restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END as wal_retention_from_restart_lsn, stat.replay_lsn, CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END as replay_lsn_else_restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name ( CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END) END as must_retain_wal_file, CASE WHEN pg_is_in_recovery() THEN NULL ELSE ( CASE WHEN stat.replay_lsn IS NULL THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END) END as wal_retention_from_replay_lsn FROM pg_catalog.pg_replication_slots slot LEFT JOIN pg_catalog.pg_stat_replication stat ON slot.active_pid = stat.pid ), standby_and_walreplica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name LIKE 'azure_standby%' or slot_name like 'wal_replica%' ), read_replica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name not LIKE 'azure_standby%' and slot_name not like 'wal_replica%' ) SELECT ( SELECT row_to_json(t1) logical_slots FROM ( SELECT ( SELECT count(*) as active FROM slots_info where slot_type = 'logical' and active = true), ( SELECT count(*) as inactive FROM slots_info where slot_type = 'logical' and active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM slots_info where slot_type = 'logical' order by replay_lsn_else_restart_lsn) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) read_replica_slots FROM ( SELECT ( SELECT count(*) as active FROM read_replica_slot_info where active = true), ( SELECT count(*) as inactive FROM read_replica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM read_replica_slot_info order by replay_lsn_else_restart_lsn limit 4) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) standby_and_walreplica_slots FROM ( SELECT ( SELECT count(*) as active FROM standby_and_walreplica_slot_info where active = true), ( SELECT count(*) as inactive FROM standby_and_walreplica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM standby_and_walreplica_slot_info) as t) as lagging_order) as t1), ( Select row_to_json(t)::text as checkpoint_info FROM ( Select ( SELECT trunc(MAX(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - xact_start))) AS max_age FROM pg_stat_activity) oldest_live_tx_age, trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - checkpoint_time)) as seconds_after_last_checkpoint, timeline_id, checkpoint_lsn, TO_CHAR(checkpoint_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as checkpoint_time, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (checkpoint_lsn) END AS checkpoint_wal_file, redo_lsn, redo_wal_file, buffers_alloc, block_size, now() - stats_reset stats_reset from pg_catalog.pg_control_checkpoint (), pg_stat_bgwriter, ( SELECT cast(current_setting('block_size') AS integer) AS block_size) as sub_query) as t), ( Select row_to_json(t)::text as archiver_info FROM ( Select trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - last_archived_time)) last_archival, (last_failed_wal IS NULL OR last_failed_wal <= last_archived_wal) is_archiving, trunc( CASE WHEN archived_count = 0 OR EXTRACT(EPOCH FROM age(now(), stats_reset)) = 0 THEN 0 ELSE CAST(archived_count AS numeric) * 60 / EXTRACT(EPOCH FROM age(now(), stats_reset)) END) wals_archived_per_minute, last_archived_wal, TO_CHAR(last_archived_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as last_archived_time, last_failed_wal, archived_count, failed_count, now() - stats_reset as stats_reset from pg_catalog.pg_stat_archiver) as t), ( Select row_to_json(t)::text as wal_upload_related_details FROM ( SELECT ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (pg_catalog.pg_current_wal_lsn ()) END as current), ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (flush_lsn) END as quorum_committed FROM slots_info where slot_type = 'physical' and sync_state = 'quorum' order by flush_lsn desc limit 1), ( SELECT CAST(pg_catalog.current_setting('azure.enforce_ha_quorom') AS boolean) AS enforce_ha_quorom), ( SELECT pg_catalog.current_setting('synchronous_standby_names') AS synchronous_standby_names), ( SELECT CAST(pg_catalog.pg_is_in_recovery() AS boolean) AS pg_is_in_recovery)) as t), ( select TO_CHAR(pg_catalog.now() at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS')) as time_fetched;

[ Date: 2025-10-10 17:26:10 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] - Bind query: yes ]

With slots_info AS ( SELECT slot.slot_name, slot.active, slot.slot_type, stat.write_lsn, stat.flush_lsn, stat.sync_state, slot.restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END as wal_retention_from_restart_lsn, stat.replay_lsn, CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END as replay_lsn_else_restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name ( CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END) END as must_retain_wal_file, CASE WHEN pg_is_in_recovery() THEN NULL ELSE ( CASE WHEN stat.replay_lsn IS NULL THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END) END as wal_retention_from_replay_lsn FROM pg_catalog.pg_replication_slots slot LEFT JOIN pg_catalog.pg_stat_replication stat ON slot.active_pid = stat.pid ), standby_and_walreplica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name LIKE 'azure_standby%' or slot_name like 'wal_replica%' ), read_replica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name not LIKE 'azure_standby%' and slot_name not like 'wal_replica%' ) SELECT ( SELECT row_to_json(t1) logical_slots FROM ( SELECT ( SELECT count(*) as active FROM slots_info where slot_type = 'logical' and active = true), ( SELECT count(*) as inactive FROM slots_info where slot_type = 'logical' and active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM slots_info where slot_type = 'logical' order by replay_lsn_else_restart_lsn) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) read_replica_slots FROM ( SELECT ( SELECT count(*) as active FROM read_replica_slot_info where active = true), ( SELECT count(*) as inactive FROM read_replica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM read_replica_slot_info order by replay_lsn_else_restart_lsn limit 4) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) standby_and_walreplica_slots FROM ( SELECT ( SELECT count(*) as active FROM standby_and_walreplica_slot_info where active = true), ( SELECT count(*) as inactive FROM standby_and_walreplica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM standby_and_walreplica_slot_info) as t) as lagging_order) as t1), ( Select row_to_json(t)::text as checkpoint_info FROM ( Select ( SELECT trunc(MAX(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - xact_start))) AS max_age FROM pg_stat_activity) oldest_live_tx_age, trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - checkpoint_time)) as seconds_after_last_checkpoint, timeline_id, checkpoint_lsn, TO_CHAR(checkpoint_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as checkpoint_time, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (checkpoint_lsn) END AS checkpoint_wal_file, redo_lsn, redo_wal_file, buffers_alloc, block_size, now() - stats_reset stats_reset from pg_catalog.pg_control_checkpoint (), pg_stat_bgwriter, ( SELECT cast(current_setting('block_size') AS integer) AS block_size) as sub_query) as t), ( Select row_to_json(t)::text as archiver_info FROM ( Select trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - last_archived_time)) last_archival, (last_failed_wal IS NULL OR last_failed_wal <= last_archived_wal) is_archiving, trunc( CASE WHEN archived_count = 0 OR EXTRACT(EPOCH FROM age(now(), stats_reset)) = 0 THEN 0 ELSE CAST(archived_count AS numeric) * 60 / EXTRACT(EPOCH FROM age(now(), stats_reset)) END) wals_archived_per_minute, last_archived_wal, TO_CHAR(last_archived_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as last_archived_time, last_failed_wal, archived_count, failed_count, now() - stats_reset as stats_reset from pg_catalog.pg_stat_archiver) as t), ( Select row_to_json(t)::text as wal_upload_related_details FROM ( SELECT ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (pg_catalog.pg_current_wal_lsn ()) END as current), ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (flush_lsn) END as quorum_committed FROM slots_info where slot_type = 'physical' and sync_state = 'quorum' order by flush_lsn desc limit 1), ( SELECT CAST(pg_catalog.current_setting('azure.enforce_ha_quorom') AS boolean) AS enforce_ha_quorom), ( SELECT pg_catalog.current_setting('synchronous_standby_names') AS synchronous_standby_names), ( SELECT CAST(pg_catalog.pg_is_in_recovery() AS boolean) AS pg_is_in_recovery)) as t), ( select TO_CHAR(pg_catalog.now() at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS')) as time_fetched;

[ Date: 2025-10-10 22:02:42 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] - Bind query: yes ]

With slots_info AS ( SELECT slot.slot_name, slot.active, slot.slot_type, stat.write_lsn, stat.flush_lsn, stat.sync_state, slot.restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END as wal_retention_from_restart_lsn, stat.replay_lsn, CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END as replay_lsn_else_restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name ( CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END) END as must_retain_wal_file, CASE WHEN pg_is_in_recovery() THEN NULL ELSE ( CASE WHEN stat.replay_lsn IS NULL THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END) END as wal_retention_from_replay_lsn FROM pg_catalog.pg_replication_slots slot LEFT JOIN pg_catalog.pg_stat_replication stat ON slot.active_pid = stat.pid ), standby_and_walreplica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name LIKE 'azure_standby%' or slot_name like 'wal_replica%' ), read_replica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name not LIKE 'azure_standby%' and slot_name not like 'wal_replica%' ) SELECT ( SELECT row_to_json(t1) logical_slots FROM ( SELECT ( SELECT count(*) as active FROM slots_info where slot_type = 'logical' and active = true), ( SELECT count(*) as inactive FROM slots_info where slot_type = 'logical' and active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM slots_info where slot_type = 'logical' order by replay_lsn_else_restart_lsn) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) read_replica_slots FROM ( SELECT ( SELECT count(*) as active FROM read_replica_slot_info where active = true), ( SELECT count(*) as inactive FROM read_replica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM read_replica_slot_info order by replay_lsn_else_restart_lsn limit 4) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) standby_and_walreplica_slots FROM ( SELECT ( SELECT count(*) as active FROM standby_and_walreplica_slot_info where active = true), ( SELECT count(*) as inactive FROM standby_and_walreplica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM standby_and_walreplica_slot_info) as t) as lagging_order) as t1), ( Select row_to_json(t)::text as checkpoint_info FROM ( Select ( SELECT trunc(MAX(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - xact_start))) AS max_age FROM pg_stat_activity) oldest_live_tx_age, trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - checkpoint_time)) as seconds_after_last_checkpoint, timeline_id, checkpoint_lsn, TO_CHAR(checkpoint_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as checkpoint_time, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (checkpoint_lsn) END AS checkpoint_wal_file, redo_lsn, redo_wal_file, buffers_alloc, block_size, now() - stats_reset stats_reset from pg_catalog.pg_control_checkpoint (), pg_stat_bgwriter, ( SELECT cast(current_setting('block_size') AS integer) AS block_size) as sub_query) as t), ( Select row_to_json(t)::text as archiver_info FROM ( Select trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - last_archived_time)) last_archival, (last_failed_wal IS NULL OR last_failed_wal <= last_archived_wal) is_archiving, trunc( CASE WHEN archived_count = 0 OR EXTRACT(EPOCH FROM age(now(), stats_reset)) = 0 THEN 0 ELSE CAST(archived_count AS numeric) * 60 / EXTRACT(EPOCH FROM age(now(), stats_reset)) END) wals_archived_per_minute, last_archived_wal, TO_CHAR(last_archived_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as last_archived_time, last_failed_wal, archived_count, failed_count, now() - stats_reset as stats_reset from pg_catalog.pg_stat_archiver) as t), ( Select row_to_json(t)::text as wal_upload_related_details FROM ( SELECT ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (pg_catalog.pg_current_wal_lsn ()) END as current), ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (flush_lsn) END as quorum_committed FROM slots_info where slot_type = 'physical' and sync_state = 'quorum' order by flush_lsn desc limit 1), ( SELECT CAST(pg_catalog.current_setting('azure.enforce_ha_quorom') AS boolean) AS enforce_ha_quorom), ( SELECT pg_catalog.current_setting('synchronous_standby_names') AS synchronous_standby_names), ( SELECT CAST(pg_catalog.pg_is_in_recovery() AS boolean) AS pg_is_in_recovery)) as t), ( select TO_CHAR(pg_catalog.now() at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS')) as time_fetched;