当前位置: 移动技术网 > IT编程>脚本编程>Python > python3 协程Unclosed client session client_session: <aiohttp.client.ClientSession object at 0x0918BAC0>

python3 协程Unclosed client session client_session: <aiohttp.client.ClientSession object at 0x0918BAC0>

2020年03月31日  | 移动技术网IT编程  | 我要评论

狐剑传,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中异步协程的使用方法介绍

如对本文有疑问,请在下面进行留言讨论,广大热心网友会与你互动!! 点击进行留言回复

相关文章:

验证码:
移动技术网