fix redis no such key (#1647)

### What problem does this PR solve?
fix Redis no such key #1614

### Type of change

- [x] Bug Fix (non-breaking change which fixes an issue)

---------

Signed-off-by: seaver <[email protected]>
Co-authored-by: Kevin Hu <[email protected]>

api/apps/system_app.py

@@ -59,9 +59,9 @@ def status():
 
     st = timer()
     try:
-        qinfo = REDIS_CONN.health(SVR_QUEUE_NAME)
-        res["redis"] = {"status": "green", "elapsed": "{:.1f}".format((timer() - st)*1000.),
-                        "pending": qinfo.get("pending", 0)}
+        if not REDIS_CONN.health():
+            raise Exception("Lost connection!")
+        res["redis"] = {"status": "green", "elapsed": "{:.1f}".format((timer() - st)*1000.)}
     except Exception as e:
         res["redis"] = {"status": "red", "elapsed": "{:.1f}".format((timer() - st)*1000.), "error": str(e)}
 

rag/utils/redis_conn.py

@@ -44,9 +44,14 @@ class RedisDB:
             logging.warning("Redis can't be connected.")
         return self.REDIS
 
-    def health(self, queue_name):
+    def health(self):
+
         self.REDIS.ping()
-        return self.REDIS.xinfo_groups(queue_name)[0]
+        a, b = 'xx', 'yy'
+        self.REDIS.set(a, b, 3)
+
+        if self.REDIS.get(a) == b:
+            return True
 
     def is_alive(self):
         return self.REDIS is not None