diff --git a/redis/redis.go b/redis/redis.go index 8209d79..1ebfe1c 100644 --- a/redis/redis.go +++ b/redis/redis.go @@ -425,17 +425,17 @@ func GetRateLimit(ctx context.Context, key string) (count int64, err error) { return } -// SetSessionCache 缓存 RAGFlow Session ID(租户+用户+方向隔离) -func SetSessionCache(ctx context.Context, tenantId, userId, chatId, sessionId string) error { - key := SessionLastActiveKeyPrefix + tenantId + ":" + userId + ":" + chatId + ":session_id" +// SetSessionCache 缓存 RAGFlow Session ID(租户+用户隔离) +func SetSessionCache(ctx context.Context, tenantId, userId, sessionId string) error { + key := SessionLastActiveKeyPrefix + tenantId + ":" + userId + ":session_id" // SETEX key 7200 value (7200秒 = 2小时,与last_active保持一致) _, err := redisClient.Do(ctx, "SETEX", key, 7200, sessionId) return err } -// GetSessionCache 获取缓存的 RAGFlow Session ID(租户+用户+方向隔离) -func GetSessionCache(ctx context.Context, tenantId, userId, chatId string) (string, error) { - key := SessionLastActiveKeyPrefix + tenantId + ":" + userId + ":" + chatId + ":session_id" +// GetSessionCache 获取缓存的 RAGFlow Session ID(租户+用户隔离) +func GetSessionCache(ctx context.Context, tenantId, userId string) (string, error) { + key := SessionLastActiveKeyPrefix + tenantId + ":" + userId + ":session_id" result, err := redisClient.Get(ctx, key) if err != nil { return "", err @@ -448,9 +448,9 @@ func GetSessionCache(ctx context.Context, tenantId, userId, chatId string) (stri return result.String(), nil } -// DelSessionCache 删除缓存的 RAGFlow Session ID(归档时调用,租户+用户+方向隔离) -func DelSessionCache(ctx context.Context, tenantId, userId, chatId string) error { - key := SessionLastActiveKeyPrefix + tenantId + ":" + userId + ":" + chatId + ":session_id" +// DelSessionCache 删除缓存的 RAGFlow Session ID(归档时调用,租户+用户隔离) +func DelSessionCache(ctx context.Context, tenantId, userId string) error { + key := SessionLastActiveKeyPrefix + tenantId + ":" + userId + ":session_id" _, err := redisClient.Del(ctx, key) return err }