Лаг репликации на primary сервере

[pkarezin]

Добрый день, столкнулись со следующей проблемой при использовании mamonsu 3.1.2 и PostgreSQL 9.6.

Если процесс postmaster будет завершен некорректно (kill -9), то после запуска сервера будет взведен триггер PostgreSQL: streaming replication lag, даже если это primary или standalone сервер.
SELECT now() - pg_last_xact_replay_timestamp() будет отображать время с момента запуска startup на сервере.

# SELECT now() - pg_last_xact_replay_timestamp();
    ?column?
----------------
 00:21:15.10736
(1 row)

[sgrinko]

Подтверждаю.
В режиме bootstrap в функции mamonsu.timestamp_get() не учтен вариант запуска данной функции на master реплике.
Дело в том, что при вычислении выражения мы получаем LSN = NULL - это даёт ложь и вычисляется ELSE

Необходимо изменить функцию mamonsu/mamonsu/plugins/pgsql/driver/pool.py :

"replication_lag_slave_query": (
	"""
	SELECT CASE WHEN coalesce(pg_last_{1}(), '0/00000000') = coalesce(pg_last_{2}(), '0/00000000')
				THEN 0
				ELSE extract (epoch FROM now() - coalesce(pg_last_xact_replay_timestamp(), now() - INTERVAL '{0} seconds'))
		   END;
	""",
	"""
	SELECT mamonsu.timestamp_get();
	"""
),

таким образом ->

"replication_lag_slave_query": (
	"""
	SELECT CASE WHEN not pg_is_in_recovery() or coalesce(pg_last_{1}(), '0/00000000') = coalesce(pg_last_{2}(), '0/00000000')
				THEN 0
				ELSE extract (epoch FROM now() - coalesce(pg_last_xact_replay_timestamp(), now() - INTERVAL '{0} seconds'))
		   END;
	""",
	"""
	SELECT mamonsu.timestamp_get();
	"""
),

[cuprumtan]

Добрый день! Добавили фикс в версию 3.3.0.

[sgrinko]

Спасибо!
Будем пробовать