Redis Cluster plugin for Flask Cache

flask_cache_redis_cluster.py

# -*- coding: utf-8 -*-
"""
Created on Wed Jan 11 17:27:53 2017
@author: richard
"""
from werkzeug.contrib.cache import (BaseCache,
                                    RedisCache,
                                    string_types)


def rediscluster(app, config, args, kwargs):
    kwargs.update(dict(
        host=config.get('CACHE_REDIS_HOST', 'localhost'),
        port=config.get('CACHE_REDIS_PORT', 6379),
    ))
    password = config.get('CACHE_REDIS_PASSWORD')
    if password:
        kwargs['password'] = password

    key_prefix = config.get('CACHE_KEY_PREFIX')
    if key_prefix:
        kwargs['key_prefix'] = key_prefix

    return RedisClusterCache(*args, **kwargs)


#: the_app/custom.py
class RedisClusterCache(RedisCache):

    """Uses the Redis key-value store as a cache backend.
    The first argument can be either a string denoting address of the Redis
    server or an object resembling an instance of a
    ``rediscluster.StrictRedisCluster`` class.
    Note: Python Redis API already takes care of encoding unicode strings on
    Any additional keyword arguments will be passed to
    ``rediscluster.StrictRedisCluster``.
    """

    def __init__(self, host='localhost', port=6379, password=None,
                 default_timeout=300, key_prefix=None, **kwargs):
        BaseCache.__init__(self, default_timeout)
        if isinstance(host, string_types):
            try:
                from rediscluster import StrictRedisCluster
            except ImportError:
                raise RuntimeError('no redis cluster module found')
            if kwargs.get('decode_responses', None):
                raise ValueError('decode_responses is not supported by '
                                 'RedisClusterCache.')
            self._client = StrictRedisCluster(host=host,
                                              port=port,
                                              password=password,
                                              **kwargs)
        else:
            self._client = host
        self.key_prefix = key_prefix or ''

Redis Cluster Flask Cache.md

Flask Cache Redis Cluster Backend

This impliments a redis cluster backend for Flask-Cache as the standard redis cache cannot handle a redis cluster.

Usage

class Config(object):

    CACHE_TYPE = 'src_dir.flask_cache_redis_cluster.rediscluster'
    CACHE_REDIS_HOST = 'redis'
    CACHE_REDIS_PORT = 6379
    CACHE_KEY_PREFIX = '<your prefix>'
    # ... other options

Put this in a PyPI module

https://github.com/Richard-Mathie/Flask-Cache-Redis-Cluster