monitor psql db

monitor-psql-db.py

import sys
import psycopg2
import psycopg2.extras
conn = psycopg2.connect("host=localhost port=5433 dbname=keycloak user=keycloak password=keycloak")

with conn.cursor(cursor_factory=psycopg2.extras.DictCursor) as cur:
    cur.execute('show pool_nodes')
    result = cur.fetchall()
    result = sorted(result, key=lambda x:x['hostname'])
    #print result
    if result[0]['status'] == 'up' and result[0]['role'] == 'primary' and result[0]['status'] == 'up':
        sys.exit(0)

#print 'db ha error. primary is not standby'
sys.exit(1)