From 878b5319278a40a3eaf9de1ac0c739a84bb6c36c Mon Sep 17 00:00:00 2001 From: Jonathan Math Date: Sun, 3 Jan 2021 11:06:20 -0500 Subject: [PATCH] add monitor route for redis_pubsub --- flask_monitor/db_monitor.py | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/flask_monitor/db_monitor.py b/flask_monitor/db_monitor.py index f5a0956a8..23ffc8df0 100644 --- a/flask_monitor/db_monitor.py +++ b/flask_monitor/db_monitor.py @@ -102,6 +102,22 @@ def db_check_redis_story(): else: abort(404) +@app.route("/db_check/redis_pubsub") +def db_check_redis_story(): + redis_host = getattr(settings, 'REDIS', {'host': 'db_redis_pubsub'}) + try: + r = redis.Redis(redis_host['host'], db=1) + except: + abort(502) + + pubsub_numpat = r.pubsub_numpat() + if pubsub_numpat: + return str(pubsub_numpat) + else: + abort(404) + + + @app.route("/db_check/redis_sessions") def db_check_redis_sessions(): redis_host = getattr(settings, 'REDIS', {'host': 'db_redis_sessions'})