aiosolr.py 文件源码

def __init__(self, url, decoder=None, timeout=60, results_cls=Results, loop=None):
        if loop is None:
            loop = asyncio.get_event_loop()
        self.loop = loop
        self.decoder = decoder or json.JSONDecoder()
        self.url = url
        self.timeout = timeout
        self.log = self._get_log()
        self.session = aiohttp.ClientSession(
            connector=aiohttp.TCPConnector(use_dns_cache=True, loop=loop),
            loop=loop)
        self.results_cls = results_cls