python - "RuntimeError: This event loop is already running";在python 3.6.5中调试aiohttp，asyncio和IDE "spyder3"-6ren

python - "RuntimeError: This event loop is already running";在python 3.6.5中调试aiohttp，asyncio和IDE "spyder3"

转载作者：太空狗更新时间：2023-10-30 01:11:27

27

4

我正在努力理解为什么我会收到“RuntimeError:此事件循环已在运行”的运行时错误。我试图从“https://aiohttp.readthedocs.io/en/stable/”运行代码片段，但是，我一直遇到同样的问题。

教程中的代码段:

import aiohttp
import asyncio
import async_timeout

async def fetch(session, url):
    async with async_timeout.timeout(10):
        async with session.get(url) as response:
            return await response.text()

async def main():
    async with aiohttp.ClientSession() as session:
        html = await fetch(session, 'http://python.org')
        print(html)

loop = asyncio.get_event_loop()
loop.run_until_complete(main())

教程摘要的 结果(从spyder IDE运行代码时):

RuntimeError:此事件循环已在运行

<!doctype html>"

...(更多html)

个人代码段(并非来自以上引用的教程):

import aiohttp
import asyncio
import time

urls = ['https://api.robinhood.com/quotes/c4f6720a-0364-4e7b-8c41-705696759e1a/']

async def fetch(client, url):
    async with client.request('get', url) as response:
        if response.status == 200:
            data = await response.text()
        else:
            data = []
        print(data)
        return(data)

async def get_async_urls(urls):
    async with aiohttp.ClientSession() as client:
        return await asyncio.gather(*(fetch(client, url) for url in urls))

if __name__ == '__main__':
    t0 = time.time()
    loop = asyncio.get_event_loop()
    results = loop.run_until_complete(get_async_urls(urls))
    print(results)
    t1 = time.time()
    total_time = t1-t0
    loop.close()

个人摘要的 结果(从spyder IDE运行代码时):

RuntimeError:此事件循环已在运行

{“ask_price”:“14.9000”，“ask_size”:100，“bid_price”:“14.0100”，“bid_size”:100，“last_trade_price”:“14.7900”，“last_extended_hours_trade_price”:“14.7900”，“previous_close”:“14.3600“，” adjusted_previous_close“:” 14.3600“，” previous_close_date“:” 2018-05-07“，” symbol“:” SURF“，” trading_halted“:false，” has_traded“:true，” last_trade_price_source“:”合并“，“updated_at”:“2018-05-08T20:01:21Z”，“乐器”:“ https://api.robinhood.com/instruments/43d56335-f2f6-4711-b650-55be2396f814/”}

个人代码段的 结果(从cmd“python personal_snippet.py”运行时):

{“ask_price”:“14.9000”，“ask_size”:100，“bid_price”:“14.0100”，“bid_size”:100，“last_trade_price”:“14.7900”，“last_extended_hours_trade_price”:“14.7900”，“previous_close”:“14.3600“，” adjusted_previous_close“:” 14.3600“，” previous_close_date“:” 2018-05-07“，” symbol“:” SURF“，” trading_halted“:false，” has_traded“:true，” last_trade_price_source“:”合并“，“updated_at”:“2018-05-08T20:01:21Z”，“乐器”:“ https://api.robinhood.com/instruments/43d56335-f2f6-4711-b650-55be2396f814/”}
['{“ask_price”:“14.9000”，“ask_size”:100，“bid_price”:“14.0100”，“bid_size”:100，“last_trade_price”:“14.7900”，“last_extended_hours_trade_price”:“14.7900”，“previous_close” :“14.3600”，“adjusted_previous_close”:“14.3600”，“previous_close_date”:“2018-05-07”，“symbol”:“SURF”，“trading_halted”:false，“has_traded”:true，“last_trade_price_source”:“合并“，” updated_at“:” 2018-05-08T20:01:21Z“，”工具“:” https://api.robinhood.com/instruments/43d56335-f2f6-4711-b650-55be2396f814/“}']

以上结果似乎表明该问题与Spyder IDE有关。

我有两个问题:

为什么会出现此错误？
似乎其他人在运行教程代码时都没有收到此错误。 (可能的答案:SPYDER3中可能出现的错误)

这似乎仅在spyder IDE中发生。我从cmd提示符中运行了两个代码段，但没有出现错误。感谢@MikhailGerasimov的建议。

假设我有两个打印命令(在第二段代码中)并且只打印了一组“数据”，那么为什么数据不返回原始调用(结果= loop.run_until_complete(get_async_urls(urls )))(可能的答案:SPYDER3中可能出现的错误)

这似乎仅在spyder IDE中发生。我从cmd提示符中运行了第二段代码，并且两张照片都出现了。感谢@MikhailGerasimov的建议。

两个问题都(可能)已答复。当我向spyder IDE提交问题时，我将引用此问题。随着事情在事物的发展方面，我将继续进行更新。如果他们回来说问题不在于他们，那么我将以略有不同的格式重新提出问题。

谢谢您的帮助!

链接到Spyder IDE的github中所引用的问题提交:
https://github.com/spyder-ide/spyder/issues/7096

最佳答案

我对Spyder有相同的问题，唯一对我有用的解决方案是使用nest_asyncio

使用以下命令安装nest_asyncio

pip install nest_asyncio

在文件中添加以下行

import nest_asyncio
nest_asyncio.apply()

而且这个问题必须解决。

从文档的

By design asyncio does not allow its event loop to be nested. This presents a practical problem: When in an environment where the event loop is already running it’s impossible to run tasks and wait for the result. Trying to do so will give the error “RuntimeError: This event loop is already running”.

The issue pops up in various environments, such as web servers, GUI applications and in Jupyter notebooks.

This module patches asyncio to allow nested use of asyncio.run and loop.run_until_complete.

关于python - "RuntimeError: This event loop is already running";在python 3.6.5中调试aiohttp，asyncio和IDE "spyder3"，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/50243393/

27

4

0

文章推荐： python - 无法导入名称 izip

文章推荐： c# - DataTable.Load() 和 DataTable = dataSet.Tables[]; 之间的区别

文章推荐： c# - ASP.NET:页面 HTML 头部渲染

文章推荐： python - 在sqlalchemy中过滤或过滤多个

python-asyncio - Python asyncio - 增加Semaphore的值
我正在我的一个项目中使用 aiohttp 并想限制每秒发出的请求数。我正在使用 asyncio.Semaphore 来做到这一点。我的挑战是我可能想要增加/减少每秒允许的请求数。例如: limit
python-asyncio - 在 asyncio 中混合异步上下文管理器和直接等待
如何混合 async with api.open() as o: ... 和 o = await api.open() 在一个功能中？自从第一次需要带有 __aenter__ 的对象以来和
python-asyncio - 使用 asyncio 做多项终极工作
有 2 个工作:“wash_clothes”(job1) 和“setup_cleaning_robot”(job2)，每个工作需要你 7 和 3 秒，你必须做到世界末日。这是我的代码: import
python-asyncio - 如何为 asyncio 任务设置名称？
我们有一种设置线程名称的方法:thread = threading.Thread(name='Very important thread', target=foo)，然后在格式化程序中使用 %(thr
python - 使用 asyncio 生成器和 asyncio.as_completed
我有一些代码，用于抓取 URL、解析信息，然后使用 SQLAlchemy 将其放入数据库中。我尝试异步执行此操作，同时限制同时请求的最大数量。这是我的代码: async def get_url(ai
Python Asyncio 未使用 asyncio.run_coroutine_threadsafe 运行新协程
1>Python Asyncio 未使用 asyncio.run_coroutine_threadsafe 运行新的协程。下面是在Mac上进行的代码测试。 ——————————————————————
python - Asyncio.gather 与 asyncio.wait
asyncio.gather和 asyncio.wait似乎有类似的用途:我有一堆我想要执行/等待的异步事情(不一定要在下一个开始之前等待一个完成)。它们使用不同的语法，并且在某些细节上有所不同，但对
python-asyncio - 属性错误 : module 'asyncio' has no attribute 'run'
我正在尝试使用 asyncio 运行以下程序: import asyncio async def main(): print('Hello') await asyncio.sleep(
python-asyncio - 如何使用 asyncio 接口(interface)阻塞和非阻塞代码
我正在尝试在事件循环之外使用协程函数。 (在这种情况下，我想在 Django 中调用一个也可以在事件循环中使用的函数) 如果不使调用函数成为协程，似乎没有办法做到这一点。我意识到 Django 是为
python - 在 asyncio.gather 中内联链 asyncio 协程
我有一个假设 asyncio.gather设想: await asyncio.gather( cor1, [cor2, cor3], cor4, ) 我要 cor2和 cor3
Python3 和 asyncio : how to implement websocket server as asyncio instance?
我有多个服务器，每个服务器都是 asyncio.start_server 返回的实例。我需要我的 web_server 与 websockets 一起使用，以便能够使用我的 javascript 客户
Python 3 asyncio - yield from vs asyncio.async 堆栈使用
我正在使用 Python 3 asyncio 框架评估定期执行的不同模式(为简洁起见省略了实际 sleep /延迟)，我有两段代码表现不同，我无法解释原因。第一个版本使用 yield from 递归调
loop.create_task 和 asyncio.run_coroutine_threadsafe 之间的 Python asyncio 区别
从事件线程外部将协程推送到事件线程的 pythonic 方法是什么？最佳答案更新信息: 从Python 3.7 高级函数asyncio.create_task(coro)开始was added并且
python-asyncio - 如何 asyncio.gather block 中的任务+使用具有 TCP 连接限制的信号量？
我有一个大型 (1M) 数据库结果集，我想为其每一行调用一个 REST API。 API 可以接受批处理请求，但我不确定如何分割 rows 生成器，以便每个任务处理一个行列表，比如 10。我宁愿不预先
python - 混合 asyncio 和 Kivy : How to start the asyncio loop and the Kivy application at the same time?
迷失在异步中。我同时在学习Kivy和asyncio，卡在了解决运行Kivy和运行asyncio循环的问题上，无论怎么转，都是阻塞调用，需要顺序执行(好吧，我希望我是错的)，例如 loop = asy
python - asyncio python 3.6 代码到 asyncio python 3.4 代码
我有这个 3.6 异步代码: async def send(command,userPath,token): async with websockets.connect('wss://127.
python - 使用 asyncio.wait_for 和 asyncio.Semaphore 时如何正确捕获 concurrent.futures._base.TimeoutError ？
首先，我需要警告你:我是 asyncio 的新手，而且我是我马上警告你，我是 asyncio 的新手，我很难想象引擎盖下的库里有什么。这是我的代码: import asyncio semaphor
python - 当 asyncio.PriorityQueue 处于 maxsize 并且我 put() 新项目时，如何将项目从 asyncio.PriorityQueue 中推出？
我有一个asyncio.PriorityQueue，用作网络爬虫的URL队列，当我调用url_queue.get时，得分最低的URL首先从队列中删除()。当队列达到 maxsize 项时，默认行为是阻
python - 在具有 asyncio.coroutine 方法的类外部声明的 asyncio event_loop 失败并显示 "AttributeError: ' NoneType' 对象没有属性 'select'“
探索 Python 3.4.0 的 asyncio 模块，我试图创建一个类，其中包含从类外部的 event_loop 调用的 asyncio.coroutine 方法。我的工作代码如下。 impor
python-3.5 - python 3 asyncio : coroutines execution order using run_until_complete(asyncio. 等待(corutines_list))
我有一个可能是无用的问题，但尽管如此，我还是觉得我错过了一些对于理解 asyncio 的工作方式可能很重要的东西。我刚刚开始熟悉 asyncio 并编写了这段非常基本的代码: import asyn

首页

博学

6Ren·AI

商城

python - "RuntimeError: This event loop is already running";在python 3.6.5中调试aiohttp，asyncio和IDE "spyder3"