python-asyncio 相关问题

此标记用于asyncio Python包,它提供了编写单线程并发代码的机制。 asyncio包提供从Python 3.4开始的异步I / O,事件循环,协同程序和任务。

为什么在调用异步函数之前会打印该函数的输出?

异步函数的行为是不同的,尽管它们几乎是相同的代码,但我不明白为什么。 我的代码是: 导入异步 异步 def func1(): 等待 asyncio.sleep(1) 优先...

回答 1 投票 0

如何将 Python 多线程套接字客户端/服务器转换为 asyncio?

我正在编写一个工具来端到端测试基于异步的服务器。最初,我打算在一个终端窗口中启动服务器,并在一个单独的窗口中运行测试,但后来我意识到它

回答 1 投票 0

为什么我的函数没有异步运行(asyncio to_thread)?

从这个视频中学习,我正在努力让我的代码运行得更快。 我有一个同步获取函数(此处由 mySynchronousFunction 表示),我想对列表中的多个值进行评估...

回答 1 投票 0

定期在Python协程/任务中工作或退出

对Python来说完全陌生。我想编写一个简单的异步函数,它每 N 秒执行一次 ps $pid ,直到收到停止信号。 即在 go 中它只是: go func(cancelCtx context.Context) { ...

回答 1 投票 0

使用 async 异步填充 Pandas Dataframe

我刚刚看到了来自 Idently 的这段很棒的视频,并尝试使用该技巧根据另一个视频填充一些数据帧列。 这是我的 MWE(实际上更像是非工作示例)代码,我在

回答 1 投票 0

我对这个简单的异步示例的理解有什么错误

我不知道如何使用aynchio。你能帮我解决这个问题吗?假设我有一些 IO 任务,我将其放入协程任务()中,需要 8 秒。我想运行一个 inf...

回答 1 投票 0

如何在Python中使用异步迭代器实现观察者模式?

我正在努力使用 asyncio 和异步迭代器在 Python 中实现观察者模式。目标是创建一个“更改流”,任务可以在其中添加更改,其他任务可以订阅...

回答 1 投票 0

是否可以用 QtAsyncio 替换从 asyncio 创建的循环?

我正在尝试在 pyside 6 中使用 QtAsyncio 库以及 python-snapcast 库,但我无法找到一种方法来替换 create_server 函数所需的 asyncio 循环

回答 1 投票 0

如何使用aiohttp和速率限制?

我本周开始学习 Python,作为第一个项目,我选择开发一个简单的应用程序,该应用程序可以从 Riot API 获取数据,对其进行处理,然后插入到 mySQL 数据库中。我法力...

回答 1 投票 0

asyncio 仅运行第一个 gpiozero 协程

我试图让 gpiozero 与我的 RPi 4 中的 asyncio 很好地配合,但遇到了一个我无法解决的问题。本质上我正在尝试通过旋转

回答 1 投票 0

使用 asyncio 与 pandas.to_sql() 内存不足

我正在尝试同时从 API 获取数据并将其保存到 SQL Server 中的表中。但我遇到了内存问题。我相信原因是因为我先等待获取任务完成,然后再

回答 1 投票 0

尝试使用 SQLAlchemy 异步 pd.to_sql()

我正在尝试以尽可能最少的方式将数据帧安全地异步写入我的 PostgreSQL 数据库。我正在努力理解与此相关的文档,并希望一些......

回答 2 投票 0

asyncio中通过事件循环来调度任务是如何工作的?

异步程序的输出不符合预期 大家好。我最近一直在深入研究 asyncio,了解事件循环、任务、协程等如何工作。从 StackOverflow 上的这个和这个帖子中,我的

回答 1 投票 0

使用redis.asyncio订阅时无法调用回调

我的网站使用 Starlette 框架并使用 websockets。我有一个派生自 WebSocketEndpoint 的类,用于处理传入的 websocket 连接。我还有另外一个班级

回答 1 投票 0

将现有的基于 Python `socket` 的类与 `asyncio` 包装并集成

我有一个用例,其中有很多 TCP/IP 客户端被捆绑到一个 Python 进程中。目前的愿望是使用asyncio为程序提供并发性。对于所有新的 TCP...

回答 1 投票 0

运行时错误:无法从正在运行的事件循环中调用 asyncio.run(),这是一个非常简单的程序

导入异步 导入 aiohttp 异步 def fetch_data(url): 与 aiohttp.ClientSession() 异步作为会话: 与 session.get(url) 异步作为响应: 数据 = 等待响应.text(...

回答 1 投票 0

如何用Python从数百个URL请求数据?

我正在使用 REST API 来提取一些数据。 我有一个大约 10k url 的列表,我可以 ping 来获取我们需要的数据。 所以,这段代码有效: 结果={} 对于 url 中的 url: 结果[url] = requests.get(url).json()

回答 3 投票 0

用于异步和同步功能的 Python 装饰器,无需重复代码

我至少见过两个装饰器的例子,它们可以与普通的 defsync_func() 和 async def async_function() 一起使用。 但所有这些示例基本上都重复了这样的装饰器代码 小鬼...

回答 1 投票 0

python 的 influxdb-client 不采用自定义时间戳

我是 InfluxDB 的新手,一直在尝试通过 influxdb-client == 1.36.1 将具有多个具有自定义时间戳的字段的数据点从字典存储到 influxdb 中 我关注了 pypi

回答 1 投票 0

等待 asyncio.create_task 在 Spyder IDE 中获取结果

我试图了解如何使用 Spyder IDE 在 python 中运行异步调用。 我编写了以下代码: 导入异步 从并发.futures 导入 ThreadPoolExecutor 事实上异步...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.