cache.py 文件源码

def _create_pool_connection(self):
        connection_kwargs = {
            'db': self._db,
            'maxsize': self.pool_size,
            'loop': self.loop,
            **{k.lower(): v for k, v in self._params.items()}
        }
        return await create_pool(
            (self._host, self._port),
            **connection_kwargs
        )