with connection.cursor() as cursor:
cursor.execute("SELECT 1; -- Healthcheck")
health = cursor.fetchone()[0] == 1size = Noneif health:
cursor.execute("select pg_database_size("postgres") as size")
size = cursor.fetchone()
return health, size@classmethoddef run(cls):
health, size = cls.pg_health()
After Change
cursor.execute("select pg_database_size("postgres") as size")
size = cursor.fetchone()
return Result(message="Service is healthy, db size {}".format(size))
return Result(message="Service is not working.", severity=Result.WARNING)
except Exception as e:
return Result(message="Service unable to connect, encountered "{}" error.".format(e),
severity=Result.ERROR)