Python asyncio 与 aiohttp 使用简单记录

2023年12月20日 203次阅读 来源: python入门

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])) # 事件循环则被用来安排协同程序的执行

 

import asyncio
import aiohttp


skus = 'xxoo1,xxoo2'
skus_list = skus.split(",")
URL = 'http://xxoo.xxoo.com/xxoo_api/'


@asyncio.coroutine
def iamsyncio_req(sku_id):
    headers = {'content-type': 'application/json'}
    req_data = {
        "x": sku_id
    }
    response = yield from aiohttp.request('POST', URL, json=req_data, headers=headers)
    print(response.json())
    body = yield from response.json()
    print(body)


if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(asyncio.wait([iamsyncio_req(sku) for sku in skus_list]))

 

 

 

 

 

    原文作者：python入门
    原文地址: https://my.oschina.net/daqing15/blog/887347
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。
点赞