Redis添加用户名支持 (#2575)

Co-authored-by: 王飞 <fei.wang@xgo.one>
hhyo · Apr 11, 2024 · 48101d9 · 48101d9
1 parent 57024f8
commit 48101d9
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/sql/engines/redis.py b/sql/engines/redis.py
@@ -29,6 +29,7 @@ def get_connection(self, db_name=None):
             return redis.cluster.RedisCluster(
                 host=self.host,
                 port=self.port,
+                username=self.user,
                 password=self.password or None,
                 encoding_errors="ignore",
                 decode_responses=True,
@@ -40,6 +41,7 @@ def get_connection(self, db_name=None):
                 host=self.host,
                 port=self.port,
                 db=db_name,
+                username=self.user,
                 password=self.password or None,
                 encoding_errors="ignore",
                 decode_responses=True,