狐剑传,alouserdu,类固醇激互性痤疮
学习了崔大神的异步协程的使用方法,代码运行的时候出现如标题的警告很是烦人,在这里记录下解决方法。
解决方法就是在session.close()之前加await
首先看下代码:
定义一个flask服务器
from flask import flask import time app = flask(__name__) @app.route('/') def index(): time.sleep(3) return 'hello!' if __name__ == '__main__': app.run(threaded=true)
运行后用python去异步请求:
import asyncio import aiohttp import time start = time.time() async def get(url): session = aiohttp.clientsession() response = await session.get(url) result = await response.text() session.close() return result async def request(): url = 'http://127.0.0.1:5000' print('waiting for', url) result = await get(url) print('get response from', url, 'result:', result) tasks = [asyncio.ensure_future(request()) for _ in range(5)] loop = asyncio.get_event_loop() loop.run_until_complete(asyncio.wait(tasks)) end = time.time() print('cost time:', end - start)
控制台输出:
一片警告,应该是版本更新,所以用法有点不同
解决:session.close()前加await
await session.close()
页面清爽很多。。。
参考:
如对本文有疑问,请在下面进行留言讨论,广大热心网友会与你互动!! 点击进行留言回复
Python 实现将numpy中的nan和inf,nan替换成对应的均值
python爬虫把url链接编码成gbk2312格式过程解析
网友评论