亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

Flask asyncio aiohttp - RuntimeError:線程'Thread-2'

Flask asyncio aiohttp - RuntimeError:線程'Thread-2'

慕斯王 2023-02-07 13:51:40
最近一直在閱讀有關 python 并發的內容 realpython - python concurrency我的主要關注asyncio點是相當新的。執行異步活動的代碼塊使用asyncio并aiohttp在直接運行時運行良好。但是,當我將代碼添加到我的燒瓶藍圖時,它會引發此錯誤:RuntimeError: There is no current event loop in thread 'Thread-2'出于演示目的,我制作了一個演示燒瓶應用程序。萬一有人想測試一下。main.pyfrom flask import Flaskfrom my_blueprint import my_blueprint#Define flask appapp = Flask(__name__)#load blueprintsapp.register_blueprint(my_blueprint,url_prefix='/demo')#start flaskif __name__ == '__main__':    app.run(debug=True)my_blueprint.pyfrom flask import Blueprint,request, jsonify,abort,make_responsefrom flask import make_responseimport asyncioimport timeimport aiohttpmy_blueprint = Blueprint('my_blueprint', __name__)@my_blueprint.route('/',methods=['GET'])def home():    #code block    async def download_site(session, url):        async with session.get(url) as response:            print("Read {0} from {1}".format(response.content_length, url))    async def download_all_sites(sites):        async with aiohttp.ClientSession() as session:            tasks = []            for url in sites:                task = asyncio.ensure_future(download_site(session, url))                tasks.append(task)            await asyncio.gather(*tasks, return_exceptions=True)    sites = ["https://www.jython.org","http://olympus.realpython.org/dice"]*20    start_time = time.time()    asyncio.get_event_loop().run_until_complete(download_all_sites(sites))    duration = time.time() - start_time    return jsonify({"status":f"Downloaded {len(sites)} sites in {duration} seconds"})    #end of code block
查看完整描述

1 回答

?
牧羊人nacy

TA貢獻1862條經驗 獲得超7個贊

編輯:看起來你的代碼是正確的。我習慣寫不同的。但是您可能正在運行 Windows 和 Python 3.8。這只是改變了 Windows 上 python 3.8 中的默認事件循環策略,而且它很容易出錯。您可以改回舊的事件循環策略:


改變:


asyncio.get_event_loop().run_until_complete(download_all_sites(sites))

進入:


asyncio.set_event_loop(asyncio.SelectorEventLoop())

asyncio.get_event_loop().run_until_complete(download_all_sites(sites))


查看完整回答
反對 回復 2023-02-07
  • 1 回答
  • 0 關注
  • 205 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號