# _*_ coding: utf-8 _*_ """ python_aiohttp.py by xianhu """ import asyncio import aiohttp # 简单实例 async def aiohttp_test01(url): async with aiohttp.ClientSession() as session: async with session.get(url) as resp: print(resp.status) print(await resp.text()) loop = asyncio.get_event_loop() tasks = [aiohttp_test01("https://api.github.com/events")] loop.run_until_complete(asyncio.wait(tasks)) loop.close() # 其他Http方法 # session.post('http://httpbin.org/post', data=b'data') # session.put('http://httpbin.org/put', data=b'data') # session.delete('http://httpbin.org/delete') # session.head('http://httpbin.org/get') # session.options('http://httpbin.org/get') # session.patch('http://httpbin.org/patch', data=b'data') # 自定义Headers # payload = {'some': 'data'} # headers = {'content-type': 'application/json'} # await session.post(url, data=json.dumps(payload), headers=headers) # 自定义Cookie # cookies = {'cookies_are': 'working'} # async with ClientSession(cookies=cookies) as session: # 访问Cookie: session.cookie_jar # 在URLs中传递参数 # 1. params = {'key1': 'value1', 'key2': 'value2'} # 2. params = [('key', 'value1'), ('key', 'value2')] # async with session.get('http://httpbin.org/get', params=params) as resp: # assert resp.url == 'http://httpbin.org/get?key2=value2&key1=value1' # 发送数据 # payload = {'key1': 'value1', 'key2': 'value2'} # async with session.post('http://httpbin.org/post', data=payload) as resp: # async with session.post(url, data=json.dumps(payload)) as resp: # print(await resp.text()) # 发送文件(1) # files = {'file': open('report.xls', 'rb')} # await session.post(url, data=files) # 发送数据(2) # data = FormData() # data.add_field('file', # open('report.xls', 'rb'), # filename='report.xls', # content_type='application/vnd.ms-excel') # await session.post(url, data=data) # 超时设置 # aync with session.get('https://github.com', timeout=60) as r: # 代理支持 # async with aiohttp.ClientSession() as session: # async with session.get("http://python.org", proxy="http://some.proxy.com") as resp: # print(resp.status) # async with aiohttp.ClientSession() as session: # proxy_auth = aiohttp.BasicAuth('user', 'pass') # async with session.get("http://python.org", proxy="http://some.proxy.com", proxy_auth=proxy_auth) as resp: # print(resp.status) # session.get("http://python.org", proxy="http://user:[email protected]") # 返回的内容 # async with session.get('https://api.github.com/events') as resp: # print(await resp.text()) # print(await resp.text(encoding='gbk')) # print(await resp.read()) # print(await resp.json()) # 返回内容较大 # with open(filename, 'wb') as fd: # while True: # chunk = await resp.content.read(chunk_size) # if not chunk: # break # fd.write(chunk) # 返回的其他变量 # async with session.get('http://httpbin.org/get') as resp: # print(resp.status) # 状态码 # print(resp.headers) # Headers # print(resp.raw_headers) # 原始Headers # print(resp.cookies) # 返回的Cookie # 访问历史History # resp = await session.get('http://example.com/some/redirect/') # resp: # resp.history: (,) # 释放返回的Response # 1. async with session.get(url) as resp: pass # 2. await resp.release() # 连接器: Connectors # conn = aiohttp.TCPConnector() # session = aiohttp.ClientSession(connector=conn) # 限制连接池大小: # conn = aiohttp.TCPConnector(limit=30) # conn = aiohttp.TCPConnector(limit=None)