Python asyncio 与 aiohttp 使用简单记录

asyncio的基本概念

asyncio是在python3.4中被引进的异步IO库。你也可以通过python3.3的pypi来安装它。它相当的复杂，而且我不会介绍太多的细节。相反，我将会解释你需要知道些什么，以利用它来写异步的代码。

简而言之，有两件事情你需要知道：协同程序和事件循环。协同程序像是方法，但是它们可以在代码中的特定点暂停和继续。当在等待一个IO（比如一个HTTP请求），同时执行另一个请求的时候，可以用来暂停一个协同程序。我们使用关键字yield from来设定一个状态，表明我们需要一个协同程序的返回值。

事件循环则被用来安排协同程序的执行。

注意：response的返回调用某些方法，类似json()，本身就是一个generate，所以需要他真实返回内容，需要yield from的关键字。

协调程序：yield from aiohttp.request.....[代码中的特定点暂停和继续, 关键字yield from来设定一个状态，表明我们需要一个协同程序的返回值]

loop.run_until_complete(asyncio.wait([iamasyncio(sku) for sku in skus_list])) # 事件循环则被用来安排协同程序的执行

1import asyncio
2import aiohttp
3
4
5skus = 'xxoo1,xxoo2'
6skus_list = skus.split(",")
7URL = 'http://xxoo.xxoo.com/xxoo_api/'
8
9
10@asyncio.coroutine
11def iamsyncio_req(sku_id):
12    headers = {'content-type': 'application/json'}
13    req_data = {
14        "x": sku_id
15    }
16    response = yield from aiohttp.request('POST', URL, json=req_data, headers=headers)
17    print(response.json())
18    body = yield from response.json()
19    print(body)
20
21
22if __name__ == '__main__':
23    loop = asyncio.get_event_loop()
24    loop.run_until_complete(asyncio.wait([iamsyncio_req(sku) for sku in skus_list]))