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

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

從 Sanic 函數調用會拋出“無法從正在運行的事件循環調用 asyncio.run()”

從 Sanic 函數調用會拋出“無法從正在運行的事件循環調用 asyncio.run()”

繁星點點滴滴 2023-08-08 18:03:55
我是異步新手。嘗試創建一個異步裝飾器來阻塞 I/O 代碼。def singletonAsyncMaker(func):    async def inner(obj, ):        loop = asyncio.get_event_loop()        tasks = (loop.run_in_executor(None, func, i) for i in obj)        return await asyncio.gather(*tasks)    def main(obj):        return asyncio.run(inner(obj))    return main@singletonAsyncMakerdef sleeper(obj):    sleep(2)    return objx = sleeper([8, 5, 6, 6, 4645, 63, 4, 6, 1, 64, 614, 24, 65, ])print(x)這通常運行良好,并且在正常的非異步函數中也運行良好,但是當通過 Sanic 服務器的路由函數調用時,它會拋出此錯誤。Traceback (most recent call last):  File "/app.py", line 99, in extractImageResponse    result = perform_textract_bytestream(images)  File "async_experiment.py", line 51, in main    return asyncio.run(inner(obj))  File "env/lib/python3.8/asyncio/runners.py", line 33, in run    raise RuntimeError(RuntimeError: asyncio.run() cannot be called from a running event [email protected]("/v0/xxxxxxxxxxxxxxx", methods=['POST'])def function_name(request):    -----------------    x = sleeper(list)    -----------------    return jsonify(json_op)嘗試將async添加到 sanicfunction_name定義并在調用之前等待sleeper(),但沒有成功。我知道 sanic 可以與 asyncio 一起使用,這對此有幫助嗎?有什么修復或解決方法嗎?
查看完整描述

1 回答

?
九州編程

TA貢獻1785條經驗 獲得超4個贊

無需asyncio.run在 Sanic 內部調用。


@app.route("/v0/xxxxxxxxxxxxxxx", methods=['POST'])

async def function_name(request):

    await call_to_some_coroutine()


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

添加回答

舉報

0/150
提交
取消
微信客服

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

幫助反饋 APP下載

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

公眾號

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