Async http client/server framework (asyncio)
For this release we completely refactored low-level implementation of http handling.
Finally uvloop gives performance improvement. Overall performance improvement
should be around 70-90% compared to 1.x version.
We took opportunity to refactor long standing api design problems across whole package. Client exceptions handling has been cleaned up and now much more straight forward. Client payload management simplified and allows to extend with any custom type. Client connection pool implementation has been redesigned as well, now there is no need for actively releasing response objects, aiohttp handles connection release automatically.
Another major change, we moved aiohttp development to public organization https://github.com/aio-libs
With this amount of api changes we had to make backward incompatible changes. Please check this migration document http://aiohttp.readthedocs.io/en/latest/migration.html
Please report problems or annoyance with with api to https://github.com/aio-libs/aiohttp
To retrieve something from the web:
import aiohttp import asyncio async def fetch(session, url): with aiohttp.Timeout(10, loop=session.loop): async with session.get(url) as response: return await response.text() async def main(loop): async with aiohttp.ClientSession(loop=loop) as session: html = await fetch(session, 'http://python.org') print(html) if __name__ == '__main__': loop = asyncio.get_event_loop() loop.run_until_complete(main(loop))
This is simple usage example:
from aiohttp import web async def handle(request): name = request.match_info.get('name', "Anonymous") text = "Hello, " + name return web.Response(text=text) async def wshandler(request): ws = web.WebSocketResponse() await ws.prepare(request) async for msg in ws: if msg.type == web.MsgType.text: await ws.send_str("Hello, {}".format(msg.data)) elif msg.type == web.MsgType.binary: await ws.send_bytes(msg.data) elif msg.type == web.MsgType.close: break return ws app = web.Application() app.router.add_get('/echo', wshandler) app.router.add_get('/', handle) app.router.add_get('/{name}', handle) web.run_app(app)
Note: examples are written for Python 3.5+ and utilize PEP-492 aka async/await. If you are using Python 3.4 please replace await with yield from and async def with @coroutine e.g.:
async def coro(...):
ret = await f()
should be replaced by:
@asyncio.coroutine
def coro(...):
ret = yield from f()
aio-libs google group: https://groups.google.com/forum/#!forum/aio-libs
Optionally you may install the cChardet and aiodns libraries (highly recommended for sake of speed).
aiohttp is offered under the Apache 2 license.
The aiohttp community would like to thank Keepsafe (https://www.getkeepsafe.com) for it’s support in the early days of the project.
The latest developer version is available in a github repository: https://github.com/aio-libs/aiohttp
If you are interested in by efficiency, AsyncIO community maintains a list of benchmarks on the official wiki: https://github.com/python/asyncio/wiki/Benchmarks
Response.write_eof.__doc__) when registering synchronous
handlers for resources. #1953run_app to gracefully exit #1932unittest_run_looprun_app() are not raise
DeprecationWarning now #1947await aiohttp.request(..) is used #1981ClientPayloadError with blank Content-Encoding header #1931deflate encoding implemented in httpbin.org/deflate #1918CRLF after POST data #1792ClientSession in response object #1985app.on_loop_available signal #1978async-tokio event loop written in Rust
https://github.com/PyO3/tokioloop.close in run_app if the user did not supply a loop.
Useful for allowing clients to specify their own cleanup before closing the
asyncio loop if they wish to tightly control loop behaviorrequest_info to response object and ClientResponseError. #1733history to ClientResponseError. #1741args and kwargs to unittest_run_loop. Useful with other
decorators, for example @patch. #1803iter_chunks to response.content object. #1805proxy_from_env to ClientRequest to read from environment
variables. #1791+ in match_info values #1816request.post() and multipart.form() #1765json to ClientSession.request() method #1726raise_for_status parameter, automatically calls
raise_for_status() on any request. #1724response.json() raises ClientReponseError exception if response’s
content type does not match #1723loop parameter for Application’s constructor2.0.0rc1 (2017-03-15)ClientWebSocketResponse.get_extra_info() #1717limit parameter indicates total concurrent connections.
New limit_per_host added, indicates total connections per endpoint. #1601raw_host for name resolution #1685ClientResponse.url to yarl.URL instance #1654allow_head=True keyword argument for add_get #1618run_app and the Command Line Interface now support serving over
Unix domain sockets for faster inter-process communication.run_app now supports passing a preexisting socket object. This can be useful
e.g. for socket-based activated applications, when binding of a socket is
done by the parent process.encoding parameter for ClientSession.request() methodversion from ClientSession.request() methodaiohttp.protocol.HttpPrefixParser #1590.started, .start() and
.can_start() method #1591sub app via app.router.add_subapp() is deprecated
use app.add_subapp() instead #1592Application.finish() and Application.register_on_finish() #1602web.Request.GET and web.Request.POSTaiohttp.web.WebSocketResponse.receive_msg() #1605ServerHttpProtocol.keep_alive_timeout attribute and
keep-alive, keep_alive_on, timeout, log constructor parameters #1606TCPConnector's` .resolve, .resolved_hosts,
.clear_resolved_hosts() attributes and resolve constructor
parameter #1607ProxyConnector #1609Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
