api.py 文件源码

def get_async_redis(self, loop=None):
        """Creates an asynchronous Redis connection.

        Parameters
        ----------
        loop = Optional[asyncio.AbstractEventLoop]
            The loop used for the asynchronous Redis connection.
        """

        if self.loop is not None and loop is None:
            loop = self.loop
        return await aioredis.create_redis(
            'redis://{}:{}'.format(cache_config['HOST'], cache_config['PORT']),
            db=cache_config['DB'], password=cache_config['PASSWORD'], loop=loop)