Method _init_client

core/utils.py:120–210

(cls, decode_responses=True, max_retries=5, retry_interval=1)

    @classmethod
    def _init_client(cls, decode_responses=True, max_retries=5, retry_interval=1):
        retry_count = 0
        while retry_count < max_retries:
            try:
                # Get connection parameters from settings or environment
                redis_host = os.environ.get("REDIS_HOST", getattr(settings, 'REDIS_HOST', 'localhost'))
                redis_port = int(os.environ.get("REDIS_PORT", getattr(settings, 'REDIS_PORT', 6379)))
                redis_db = int(os.environ.get("REDIS_DB", getattr(settings, 'REDIS_DB', 0)))
                redis_password = os.environ.get("REDIS_PASSWORD", getattr(settings, 'REDIS_PASSWORD', ''))
                redis_user = os.environ.get("REDIS_USER", getattr(settings, 'REDIS_USER', ''))

                # Use standardized settings
                socket_timeout = getattr(settings, 'REDIS_SOCKET_TIMEOUT', 5)
                socket_connect_timeout = getattr(settings, 'REDIS_SOCKET_CONNECT_TIMEOUT', 5)
                health_check_interval = getattr(settings, 'REDIS_HEALTH_CHECK_INTERVAL', 30)
                socket_keepalive = getattr(settings, 'REDIS_SOCKET_KEEPALIVE', True)
                retry_on_timeout = getattr(settings, 'REDIS_RETRY_ON_TIMEOUT', True)

                # TLS params from settings (empty dict when TLS is disabled)
                ssl_params = getattr(settings, 'REDIS_SSL_PARAMS', {})

                # Create Redis client with better defaults
                client = redis.Redis(
                    host=redis_host,
                    port=redis_port,
                    db=redis_db,
                    password=redis_password if redis_password else None,
                    username=redis_user if redis_user else None,
                    socket_timeout=socket_timeout,
                    socket_connect_timeout=socket_connect_timeout,
                    socket_keepalive=socket_keepalive,
                    health_check_interval=health_check_interval,
                    retry_on_timeout=retry_on_timeout,
                    decode_responses=decode_responses,
                    **ssl_params
                )

                # Validate connection with ping
                client.ping()

                # Disable persistence on first connection - improves performance
                # Only try to disable if not in a read-only environment
                try:
                    client.config_set('save', '')  # Disable RDB snapshots
                    client.config_set('appendonly', 'no')  # Disable AOF logging

                    # Disable protected mode when in debug mode
                    if os.environ.get('DISPATCHARR_DEBUG', '').lower() == 'true':
                        client.config_set('protected-mode', 'no')  # Disable protected mode in debug
                        logger.warning("Redis protected mode disabled for debug environment")

                    logger.trace("Redis persistence disabled for better performance")
                except redis.exceptions.ResponseError as e:
                    # Improve error handling for Redis configuration errors
                    if "OOM" in str(e):
                        logger.error(f"Redis OOM during configuration: {e}")
                        # Try to increase maxmemory as an emergency measure
                        try: