修复修复fix redis cluster异常问题

requirements.txt

@@ -12,6 +12,7 @@ mysql-replication==0.22
 django-q==1.3.9
 django-redis==5.2.0
 redis==3.5.3
+redis-py-cluster==2.1.3
 pyodbc==4.*
 gunicorn==22.0.0
 pyecharts==2.0.4

sql/engines/redis.py

@@ -11,6 +11,7 @@
 import shlex
 
 import redis
+import rediscluster
 import logging
 import traceback
 
@@ -27,15 +28,12 @@ class RedisEngine(EngineBase):
     def get_connection(self, db_name=None):
         db_name = db_name or self.db_name
         if self.mode == "cluster":
-            return redis.cluster.RedisCluster(
-                host=self.host,
-                port=self.port,
-                username=self.user,
-                password=self.password or None,
-                encoding_errors="ignore",
+            return rediscluster.RedisCluster(
+                startup_nodes=[{"host": self.host, "port": self.port}],
                 decode_responses=True,
                 socket_connect_timeout=10,
                 ssl=self.is_ssl,
+                password=self.password,
             )
         else:
             return redis.Redis(

src/docker/Dockerfile

@@ -11,7 +11,6 @@ RUN apt-get update \
     && apt-get install -yq --no-install-recommends nginx mariadb-client \
     && source venv4archery/bin/activate \
     && pip install -r /opt/archery/requirements.txt \
-    && pip install "redis>=4.1.0" \
     && cp -f /opt/archery/src/docker/nginx.conf /etc/nginx/ \
     && cp -f /opt/archery/src/docker/supervisord.conf /etc/ \
     && mv /opt/sqladvisor /opt/archery/src/plugins/ \