首页 > 编程语言 > 详细

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

时间:2020-03-31 13:07:21      阅读:139      评论:0      收藏:0      [点我收藏+]

学习了崔大神的异步协程的使用方法,代码运行的时候出现如标题的警告很是烦人,在这里记录下解决方法。

解决方法就是在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()

技术分享图片

 

 页面清爽很多。。。

参考:https://stackoverflow.com/questions/54807599/aiohttp-unclosed-client-session-client-session

静觅 » Python中异步协程的使用方法介绍

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

原文:https://www.cnblogs.com/nmsghgnv/p/12603084.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!