from redis import BlockingConnectionPool, StrictRedis

import config


def init_redis():
    host = config.REDIS_HOST
    port = config.REDIS_PORT
    pool_size = config.CACHE_MAX_CONNECTION_POOL_SIZE

    connection_pool = BlockingConnectionPool(host=host, port=port, max_connections=pool_size)

    client = StrictRedis(connection_pool=connection_pool, decode_responses=True)

    return client