此标记用于asyncio Python包,它提供了编写单线程并发代码的机制。 asyncio包提供从Python 3.4开始的异步I / O,事件循环,协同程序和任务。
异步函数的行为是不同的,尽管它们几乎是相同的代码,但我不明白为什么。 我的代码是: 导入异步 异步 def func1(): 等待 asyncio.sleep(1) 优先...
如何将 Python 多线程套接字客户端/服务器转换为 asyncio?
我正在编写一个工具来端到端测试基于异步的服务器。最初,我打算在一个终端窗口中启动服务器,并在一个单独的窗口中运行测试,但后来我意识到它
为什么我的函数没有异步运行(asyncio to_thread)?
从这个视频中学习,我正在努力让我的代码运行得更快。 我有一个同步获取函数(此处由 mySynchronousFunction 表示),我想对列表中的多个值进行评估...
对Python来说完全陌生。我想编写一个简单的异步函数,它每 N 秒执行一次 ps $pid ,直到收到停止信号。 即在 go 中它只是: go func(cancelCtx context.Context) { ...
使用 async 异步填充 Pandas Dataframe
我刚刚看到了来自 Idently 的这段很棒的视频,并尝试使用该技巧根据另一个视频填充一些数据帧列。 这是我的 MWE(实际上更像是非工作示例)代码,我在
我不知道如何使用aynchio。你能帮我解决这个问题吗?假设我有一些 IO 任务,我将其放入协程任务()中,需要 8 秒。我想运行一个 inf...
我正在努力使用 asyncio 和异步迭代器在 Python 中实现观察者模式。目标是创建一个“更改流”,任务可以在其中添加更改,其他任务可以订阅...
是否可以用 QtAsyncio 替换从 asyncio 创建的循环?
我正在尝试在 pyside 6 中使用 QtAsyncio 库以及 python-snapcast 库,但我无法找到一种方法来替换 create_server 函数所需的 asyncio 循环
我本周开始学习 Python,作为第一个项目,我选择开发一个简单的应用程序,该应用程序可以从 Riot API 获取数据,对其进行处理,然后插入到 mySQL 数据库中。我法力...
我试图让 gpiozero 与我的 RPi 4 中的 asyncio 很好地配合,但遇到了一个我无法解决的问题。本质上我正在尝试通过旋转
使用 asyncio 与 pandas.to_sql() 内存不足
我正在尝试同时从 API 获取数据并将其保存到 SQL Server 中的表中。但我遇到了内存问题。我相信原因是因为我先等待获取任务完成,然后再
尝试使用 SQLAlchemy 异步 pd.to_sql()
我正在尝试以尽可能最少的方式将数据帧安全地异步写入我的 PostgreSQL 数据库。我正在努力理解与此相关的文档,并希望一些......
异步程序的输出不符合预期 大家好。我最近一直在深入研究 asyncio,了解事件循环、任务、协程等如何工作。从 StackOverflow 上的这个和这个帖子中,我的
我的网站使用 Starlette 框架并使用 websockets。我有一个派生自 WebSocketEndpoint 的类,用于处理传入的 websocket 连接。我还有另外一个班级
将现有的基于 Python `socket` 的类与 `asyncio` 包装并集成
我有一个用例,其中有很多 TCP/IP 客户端被捆绑到一个 Python 进程中。目前的愿望是使用asyncio为程序提供并发性。对于所有新的 TCP...
运行时错误:无法从正在运行的事件循环中调用 asyncio.run(),这是一个非常简单的程序
导入异步 导入 aiohttp 异步 def fetch_data(url): 与 aiohttp.ClientSession() 异步作为会话: 与 session.get(url) 异步作为响应: 数据 = 等待响应.text(...
我正在使用 REST API 来提取一些数据。 我有一个大约 10k url 的列表,我可以 ping 来获取我们需要的数据。 所以,这段代码有效: 结果={} 对于 url 中的 url: 结果[url] = requests.get(url).json()
我至少见过两个装饰器的例子,它们可以与普通的 defsync_func() 和 async def async_function() 一起使用。 但所有这些示例基本上都重复了这样的装饰器代码 小鬼...
python 的 influxdb-client 不采用自定义时间戳
我是 InfluxDB 的新手,一直在尝试通过 influxdb-client == 1.36.1 将具有多个具有自定义时间戳的字段的数据点从字典存储到 influxdb 中 我关注了 pypi
等待 asyncio.create_task 在 Spyder IDE 中获取结果
我试图了解如何使用 Spyder IDE 在 python 中运行异步调用。 我编写了以下代码: 导入异步 从并发.futures 导入 ThreadPoolExecutor 事实上异步...