class CustomProxyConnector(ProxyConnector):
async def connect(self, req, traces):
if self._proxy_type.is_http():
req.update_proxy(self.proxy_url.with_scheme('http'), None,
req.proxy_headers)
return await super(ProxyConnector, self).connect(
req=req, traces=traces)
conn = CustomProxyConnector.from_url(url=proxy)
async with aiohttp.ClientSession(connector=conn
) as session:
pip install mutagen