F.35. pg_walinspect — проÑмотр журнала предзапиÑи на низком уровне #
Модуль pg_walinspect предоÑтавлÑет SQL-функции Ð´Ð»Ñ Ð¿Ñ€Ð¾Ñмотра журнала предзапиÑи на низком уровне. Он работает Ñ Ð·Ð°Ð¿ÑƒÑ‰ÐµÐ½Ð½Ñ‹Ð¼ клаÑтером баз данных PostgreSQL и может быть полезен Ð´Ð»Ñ Ñ†ÐµÐ»ÐµÐ¹ отладки, анализа, отчётноÑти или обучениÑ. Модуль похож на pg_waldump, но работает через SQL, а не как Ð¾Ñ‚Ð´ÐµÐ»ÑŒÐ½Ð°Ñ ÑƒÑ‚Ð¸Ð»Ð¸Ñ‚Ð°.
Ð’Ñе функции Ñтого Ð¼Ð¾Ð´ÑƒÐ»Ñ Ð²Ñ‹Ð´Ð°ÑŽÑ‚ информацию из WAL, отноÑÑщуюÑÑ Ðº текущей линии времени Ñервера.
Примечание
Функции pg_walinspect зачаÑтую вызываютÑÑ Ñ Ð°Ñ€Ð³ÑƒÐ¼ÐµÐ½Ñ‚Ð¾Ð¼ LSN, который задаёт начало интереÑующей запиÑи WAL. Тем не менее некоторые функции, например pg_logical_emit_message, возвращают LSN поÑле только что добавленной запиÑи.
ПодÑказка
Ð’Ñе функции pg_walinspect, которые показывают информацию о запиÑÑÑ…, попадающих в определённый диапазон значений LSN, могут принимать конечные_lsn поÑле текущего LSN Ñервера. При иÑпользовании конечного_lsn «из будущего» ошибки не возникнет.
Может быть удобным указать значение FFFFFFFF/FFFFFFFF (макÑимально допуÑтимое значение pg_lsn) в качеÑтве аргумента конечного_lsn. Ðто аналогично варианту указать конечный_lsn, Ñовпадающий Ñ Ñ‚ÐµÐºÑƒÑ‰Ð¸Ð¼ LSN Ñервера.
По умолчанию иÑпользовать Ñти функции разрешено только ÑуперпользователÑм и ролÑм, включённым в роль pg_read_server_files. Суперпользователь может дать доÑтуп другим, воÑпользовавшиÑÑŒ командой GRANT.
F.35.1. Функции общего Ð½Ð°Ð·Ð½Ð°Ñ‡ÐµÐ½Ð¸Ñ #
-
pg_get_wal_record_info(in_lsn pg_lsn) returns record# Получает информацию о запиÑи WAL, ÐºÐ¾Ñ‚Ð¾Ñ€Ð°Ñ Ñ€Ð°Ñположена по
заданному_lsnили поÑле него. Ðапример:postgres=# SELECT * FROM pg_get_wal_record_info('0/E419E28'); -[ RECORD 1 ]----+------------------------------------------------- start_lsn | 0/E419E28 end_lsn | 0/E419E68 prev_lsn | 0/E419D78 xid | 0 resource_manager | Heap2 record_type | VACUUM record_length | 58 main_data_length | 2 fpi_length | 0 description | nunused: 5, unused: [1, 2, 3, 4, 5] block_ref | blkref #0: rel 1663/16385/1249 fork main blk 364ЕÑли
заданный_lsnне находитÑÑ Ð² начале запиÑи WAL, будет показана Ð¸Ð½Ñ„Ð¾Ñ€Ð¼Ð°Ñ†Ð¸Ñ Ð¾ Ñледующей корректной запиÑи WAL. ЕÑли такой запиÑи WAL нет, Ñ„ÑƒÐ½ÐºÑ†Ð¸Ñ Ð²Ñ‹Ð´Ð°ÑÑ‚ ошибку.-
pg_get_wal_records_info(start_lsn pg_lsn, end_lsn pg_lsn) returns setof record# Получает информацию обо вÑех корректных запиÑÑÑ… WAL между
начальным_lsnиконечным_lsn. Возвращает одну Ñтроку Ð´Ð»Ñ ÐºÐ°Ð¶Ð´Ð¾Ð¹ запиÑи WAL. Пример иÑÐ¿Ð¾Ð»ÑŒÐ·Ð¾Ð²Ð°Ð½Ð¸Ñ Ñ„ÑƒÐ½ÐºÑ†Ð¸Ð¸:postgres=# SELECT * FROM pg_get_wal_records_info('0/1E913618', '0/1E913740') LIMIT 1; -[ RECORD 1 ]----+-------------------------------------------------------------- start_lsn | 0/1E913618 end_lsn | 0/1E913650 prev_lsn | 0/1E9135A0 xid | 0 resource_manager | Standby record_type | RUNNING_XACTS record_length | 50 main_data_length | 24 fpi_length | 0 description | nextXid 33775 latestCompletedXid 33774 oldestRunningXid 33775 block_ref |Ð¤ÑƒÐ½ÐºÑ†Ð¸Ñ Ð²Ñ‹Ð´Ð°Ñ‘Ñ‚ ошибку, еÑли
начальный_lsnнедоÑтупен.-
pg_get_wal_block_info(start_lsn pg_lsn, end_lsn pg_lsn, show_data boolean DEFAULT true) returns setof record# Получает информацию о каждой ÑÑылке на блок из вÑех корректных запиÑей WAL между
начальным_lsnиконечным_lsnÑ Ð¾Ð´Ð½Ð¾Ð¹ или более ÑÑылок на блок. Возвращает одну Ñтроку Ð´Ð»Ñ ÑÑылки на блок Ð´Ð»Ñ ÐºÐ°Ð¶Ð´Ð¾Ð¹ запиÑи WAL. Ðапример:postgres=# SELECT * FROM pg_get_wal_block_info('0/1230278', '0/12302B8'); -[ RECORD 1 ]-----+----------------------------------- start_lsn | 0/1230278 end_lsn | 0/12302B8 prev_lsn | 0/122FD40 block_id | 0 reltablespace | 1663 reldatabase | 1 relfilenode | 2658 relforknumber | 0 relblocknumber | 11 xid | 341 resource_manager | Btree record_type | INSERT_LEAF record_length | 64 main_data_length | 2 block_data_length | 16 block_fpi_length | 0 block_fpi_info | description | off: 46 block_data | \x00002a00070010402630000070696400 block_fpi_data |Ð’ Ñтом примере раÑÑмотрена запиÑÑŒ WAL, ÑÐ¾Ð´ÐµÑ€Ð¶Ð°Ñ‰Ð°Ñ Ñ‚Ð¾Ð»ÑŒÐºÐ¾ одну ÑÑылку на блок, однако во многих запиÑÑÑ… WAL таких ÑÑылок неÑколько. Строки, возвращаемые функцией
pg_get_wal_block_info, будут гарантированно иметь уникальную комбинациюначального_lsnиid_блока.Ð‘Ð¾Ð»ÑŒÑˆÐ°Ñ Ñ‡Ð°ÑÑ‚ÑŒ показанной здеÑÑŒ информации Ñовпадает Ñ Ð²Ñ‹Ð²Ð¾Ð´Ð¾Ð¼ функции
pg_get_wal_records_info, при уÑловии передачи одинаковых аргументов. Однакоpg_get_wal_block_infoвыводит информацию из каждой запиÑи WAL в раÑширенном виде, добавлÑÑ Ð² вывод по одной Ñтроке Ð´Ð»Ñ ÐºÐ°Ð¶Ð´Ð¾Ð¹ ÑÑылки на блок, поÑтому некоторые детали отÑлеживаютÑÑ Ð½Ð° уровне ÑÑылки на блок, а не на уровне целой запиÑи. Ð¢Ð°ÐºÐ°Ñ Ñтруктура полезна при работе Ñ Ð·Ð°Ð¿Ñ€Ð¾Ñами, которые отÑлеживают изменение отдельных блоков Ñ Ñ‚ÐµÑ‡ÐµÐ½Ð¸ÐµÐ¼ времени. Обратите внимание, что Ð´Ð»Ñ Ð·Ð°Ð¿Ð¸Ñей без ÑÑылок на блоки (например, запиÑи WAL длÑCOMMIT), Ñтроки возвращатьÑÑ Ð½Ðµ будут, поÑтому функциÑpg_get_wal_block_infoдейÑтвительно может возвращать меньше Ñтрок, чем функциÑpg_get_wal_records_info.Параметры
reltablespace,reldatabaseиrelfilenodeÑÑылаютÑÑ Ð½Ð°pg_tablespace.oid,pg_database.oidиpg_class.relfilenodeÑоответÑтвенно. Полеrelforknumberобозначает номер ÑÐ»Ð¾Ñ Ð² отношении Ð´Ð»Ñ ÑÑылки на блок (за подробноÑÑ‚Ñми обратитеÑÑŒ кcommon/relpath.h).ПодÑказка
ФункциÑ
pg_filenode_relation(Ñм. Таблицу 9.101) позволÑет определить, какое отношение было изменено первоначально.Клиенты могут избежать издержек материализации данных блока, что может ÑущеÑтвенно уÑкорить выполнение функции. Когда длÑ
show_dataзадано значениеfalse, значениÑblock_dataиblock_fpi_dataопуÑкаютÑÑ (то еÑÑ‚ÑŒ выходные аргументыblock_dataиblock_fpi_dataпринимают значениеNULLÐ´Ð»Ñ Ð²Ñех возвращаемых Ñтрок). Очевидно, что Ð¿Ð¾Ð´Ð¾Ð±Ð½Ð°Ñ Ð¾Ð¿Ñ‚Ð¸Ð¼Ð¸Ð·Ð°Ñ†Ð¸Ñ Ð¾ÑущеÑтвима только Ð´Ð»Ñ Ð·Ð°Ð¿Ñ€Ð¾Ñов, которым на Ñамом деле не требуютÑÑ Ð´Ð°Ð½Ð½Ñ‹Ðµ блоков.Ð¤ÑƒÐ½ÐºÑ†Ð¸Ñ Ð²Ñ‹Ð´Ð°Ñ‘Ñ‚ ошибку, еÑли
начальный_lsnнедоÑтупен.-
pg_get_wal_stats(start_lsn pg_lsn, end_lsn pg_lsn, per_record boolean DEFAULT false) returns setof record# Выдаёт ÑтатиÑтику по вÑем корректным запиÑÑм WAL между
начальным_lsnиконечным_lsn. По умолчанию возвращает одну Ñтроку Ð´Ð»Ñ ÐºÐ°Ð¶Ð´Ð¾Ð³Ð¾ типаменеджера_реÑурÑов(resource_manager). Когдапо_типу_запиÑиимеет значениеtrue, то возвращает отдельные Ñтроки Ð´Ð»Ñ Ñ€Ð°Ð·Ð½Ñ‹Ñ…Ñ‚Ð¸Ð¿Ð¾Ð²_запиÑей(record_type). Пример иÑÐ¿Ð¾Ð»ÑŒÐ·Ð¾Ð²Ð°Ð½Ð¸Ñ Ñ„ÑƒÐ½ÐºÑ†Ð¸Ð¸:postgres=# SELECT * FROM pg_get_wal_stats('0/1E847D00', '0/1E84F500') WHERE count > 0 AND "resource_manager/record_type" = 'Transaction'; LIMIT 1; -[ RECORD 1 ]----------------+------------------- resource_manager/record_type | Transaction count | 2 count_percentage | 8 record_size | 875 record_size_percentage | 41.23468426013195 fpi_size | 0 fpi_size_percentage | 0 combined_size | 875 combined_size_percentage | 2.8634072910530795Ð¤ÑƒÐ½ÐºÑ†Ð¸Ñ Ð²Ñ‹Ð´Ð°Ñ‘Ñ‚ ошибку, еÑли
начальный_lsnнедоÑтупен.
F.35.2. Ðвтор #
Бхарат Рупиредди (Bharath Rupireddy) <[email protected]>