def _async_request_(self, method, url, verify, params, headers, data):
connector = aiohttp.TCPConnector(verify_ssl=verify)
async with aiohttp.ClientSession(connector=connector) as session:
if data is not None:
async with getattr(session, method)(url, params=params,
headers=headers, data=data) as response:
data = await response.read()
result = resources.loads(data.decode('UTF-8'))
else:
async with getattr(session, method)(url, params=params,
headers=headers) as response:
data = await response.read()
result = resources.loads(data.decode('UTF-8'))
if result.__kind__ != getattr(self, '_%s_type_' % method):
raise Exception(str(result))
return result
评论列表
文章目录