AsyncRedis

asyncredis.py

import tornadoredis


class AsyncRedis(Redis):

    CONNECTION_POOLS = {}

    @classmethod
    def get_conn(cls, name='DEFAULT'):
        host, port, db = cls._get_config(name)
        key = '{}:{}'.format(host, port)

        pool = cls.CONNECTION_POOLS.get(key)
        if not pool:
            pool = tornadoredis.ConnectionPool(
                max_connections=10, wait_for_available=True,  # ConnectionPool kwargs
                host=host, port=port, # Connection kwargs
            )
            cls.CONNECTION_POOLS[key] = pool
        return tornadoredis.Client(connection_pool=pool, selected_db=db)