connection.py 文件源码

def _get_connector(ssl_context):
    if _scheme in SECURE_SCHEMES:
        if ssl_context is None:
            raise ValueError("Please pass ssl_context for secure protocol")

        if _client_module == AIOHTTP_CLIENT_MODULE:
            import aiohttp
            connector = aiohttp.TCPConnector(ssl_context=ssl_context,
                                             loop=loop)

        elif _client_module == TORNADO_CLIENT_MODULE:
            from functools import partial
            from tornado import httpclient
            connector = partial(
                httpclient.HTTPRequest, ssl_options=sslcontext)
        else:
            raise ValueError("Unknown client module")
    elif _scheme in INSECURE_SCHEMES:
        connector = None
    else:
        raise ValueError("Unknown protocol")
    return connector