- aiohttp介绍
- 一个用于asyncio和python的异步http客户端/服务端
- 支持客户端和http服务器
- 在没有回调地狱的情况下支持服务器websockers和客户端websocket开箱即用
- web服务器具有中间件,信号和可插拔路由
- 安装
pip3 install aiohttp-
pip3 install cchardet可选库 -
pip3 install aiodns加快客户端api的dns解析
- 发送一个http请求
import asyncio
import aiohttp
async with aiohttp.ClientSession() as session:
async with session.get('http://httpbin.org/get') as resp:
print(resp.status)
print(await resp.text())
- 解释：在这使用了一个ClientSession的实例session调用了ClientResponse对象的resp实例，我们可以从resp这个实例中获取所有的信息
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/head')
session.options('http://httpbin.org/options')
- Note：不要为每个请求单独创建一个会话，很可能每个应用程序都只需要一个会话来完成所有的请求
- 会话上下文管理器的使用并不是强制性的，但是不用会话上下文管理器创建会话时应该调用await session.close()，手动关闭会话
import asyncio
import aiohttp
session = aiohttp.ClientSession()
async with session.get(''):
...
await session.close()
- 在url中传递参数
- 如果希望在url中传递一些参数，可以构建一个字典用于存放参数的键跟值，然后传递给get方法的params关键字参数
params = {'key1':'value1', 'key2': 'value2'}
async with session.get('http://httpbin.org', params=params) as resp:
print(resp.url)
- 相应内容和状态码
import asyncio
import aiohttp
async with session.get(url) as resp:
print(resp.status) # http状态码
print(await resp.text()) # 响应内容
- Note:可以在text()方法中指定自定义的编码
await resp.text(encoding='gb2312')
- 二进制响应内容
- 对于非文本请求，可以以字节为单位访问响应正文
print(await resp.read())
- 所有的会话的请求方法，如request(),ClientSession.get(), ClientSession.post()等接受json参数
async with aiohttp.ClientSession() as session:
async with session.post(url, json={"test": "object"})
Note: 默认情况下，session使用python的标准库json模块进行序列化。但是可以使用不同的serializer。ClientSession接受json_serialize参数
import ujson
async with aiohttp.ClientSession(json_serializse=ujson.dumps) as session:
await session.post(url, json={"txt": "ojk"})
Note: ujson库比标准库中的json库更快但是稍微不兼容
- json响应内容
- 如果需要处理json数据，session内置了一个json解释吗器
async with session.get(url) as resp:
print(await resp.json())
Note：如果json解码失败将引发异常，可以为json()的调用指定自定义的编码和解码功能
- 超时
- 超时设置存储在ClientTimeout数据结构中。
- 默认情况下，aiohttp使用total５分钟超时，这意味的整个操作应该在5分钟内完成
- 该值可以被session的超时参数覆盖
timeout = aiohttp.ClientTimeout(total=60)
async with aiohttp.ClientSession(timeout=timeout) as session:
...
- ClientTimeout支持的字段有以下
- total:整个操作时间包括连接的建立，请求的发送和响应
- sock_connect:时间包括建立的新连接，或者如果超出连接池限制，则等待池中的空闲连接
- sock_read:从等待方读取新数据部分之间的最大允许超时时间
- Note:所有字段都是浮点数，None或者０禁用特定的超时检查
aiohttp.ClientTimeout(total=5*60, connect=None, sock_connect=None, sock_read=None)
that's all
ps:后续补上高级使用
