fix: updated Archive Queue query to fit PG 10- wal_segment_size

Author: cuprumtan

mamonsu/plugins/pgsql/archive_command.py

@@ -10,10 +10,14 @@ class ArchiveCommand(Plugin):
     Interval = 60
 
     # if streaming replication is on, archive queue length and size will always be 0 for replicas
+
+    # TODO:
+    # - check type compatibility
+    # - check coalesce operator need
     query_agent_count_files = """
     WITH values AS (
     SELECT
-    4096/(coalesce(pg_settings.setting::bigint/1024/1024, 1)) AS segment_parts_count,
+    4096/(ceil(pg_settings.setting::numeric/1024/1024)) AS segment_parts_count,
     setting::bigint AS segment_size,
     ('x' || substring(pg_stat_archiver.last_archived_wal from 9 for 8))::bit(32)::int AS last_wal_div,
     ('x' || substring(pg_stat_archiver.last_archived_wal from 17 for 8))::bit(32)::int AS last_wal_mod,
@@ -29,7 +33,7 @@ class ArchiveCommand(Plugin):
     query_agent_size_files = """
     WITH values AS (
     SELECT
-    4096/(coalesce(pg_settings.setting::bigint/1024/1024, 1)) AS segment_parts_count,
+    4096/(ceil(pg_settings.setting::numeric/1024/1024)) AS segment_parts_count,
     setting::bigint AS segment_size,
     ('x' || substring(pg_stat_archiver.last_archived_wal from 9 for 8))::bit(32)::int AS last_wal_div,
     ('x' || substring(pg_stat_archiver.last_archived_wal from 17 for 8))::bit(32)::int AS last_wal_mod,
@@ -61,7 +65,7 @@ def run(self, zbx):
         query_queue = """
             WITH values AS (
             SELECT
-            4096/(coalesce(pg_settings.setting::bigint/1024/1024, 1)) AS segment_parts_count,
+            4096/(ceil(pg_settings.setting::numeric/1024/1024)) AS segment_parts_count,
             setting::bigint AS segment_size,
             ('x' || substring(pg_stat_archiver.last_archived_wal from 9 for 8))::bit(32)::int AS last_wal_div,
             ('x' || substring(pg_stat_archiver.last_archived_wal from 17 for 8))::bit(32)::int AS last_wal_mod,

mamonsu/tools/bootstrap/sql.py

@@ -113,7 +113,7 @@
 RETURNS TABLE(COUNT_FILES BIGINT, SIZE_FILES BIGINT) AS $$
 WITH values AS (
 SELECT
-4096/(coalesce(pg_settings.setting::bigint/1024/1024, 1)) AS segment_parts_count,
+4096/(ceil(pg_settings.setting::numeric/1024/1024)) AS segment_parts_count,
 setting::bigint AS segment_size,
 ('x' || substring(pg_stat_archiver.last_archived_wal from 9 for 8))::bit(32)::int AS last_wal_div,
 ('x' || substring(pg_stat_archiver.last_archived_wal from 17 for 8))::bit(32)::int AS last_wal_mod,