From 2065b092c59d12c462fa45839e49c25dd7ffe3a2 Mon Sep 17 00:00:00 2001
From: "jim02.he" <jim02.he@vipshop.com>
Date: Thu, 19 Jun 2025 17:18:11 +0800
Subject: [PATCH] feat: Add support for custom Redis Cluster users

This introduces the ability to specify a custom username for authenticating with Redis Clusters.
---
 api/configs/middleware/cache/redis_config.py | 5 +++++
 api/extensions/ext_redis.py                  | 1 +
 2 files changed, 6 insertions(+)

diff --git a/api/configs/middleware/cache/redis_config.py b/api/configs/middleware/cache/redis_config.py
index 916f52e165..3aa14012c2 100644
--- a/api/configs/middleware/cache/redis_config.py
+++ b/api/configs/middleware/cache/redis_config.py
@@ -84,6 +84,11 @@ class RedisConfig(BaseSettings):
         default=None,
     )
 
+    REDIS_CLUSTERS_USERNAME: Optional[str] = Field(
+        description="Username for Redis Clusters authentication (Required if a custom username is used)",
+        default=None,
+    )
+
     REDIS_SERIALIZATION_PROTOCOL: int = Field(
         description="Redis serialization protocol (RESP) version",
         default=3,
diff --git a/api/extensions/ext_redis.py b/api/extensions/ext_redis.py
index c283b1b7ca..74c47ed7f7 100644
--- a/api/extensions/ext_redis.py
+++ b/api/extensions/ext_redis.py
@@ -96,6 +96,7 @@ def init_app(app: DifyApp):
         redis_client.initialize(
             RedisCluster(
                 startup_nodes=nodes,
+                username=dify_config.REDIS_CLUSTERS_USERNAME,
                 password=dify_config.REDIS_CLUSTERS_PASSWORD,
                 protocol=resp_protocol,
                 cache_config=clientside_cache_config,