python-asyncio 相关问题

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

从 aiohttp 服务器调用 aiohttp 客户端方法会导致 RuntimeError

我正在尝试创建具有以下布局的支付微服务: 客户端工作正常,直到在 aiohttp 服务器端使用 aiohttp 客户端方法。 我有一堂课创造...

回答 1 投票 0

从 contextlib asynccontextmanager 产生 future 不安全吗?

我有一个问题,我需要检查日志文件中执行的两点之间是否发生了某些情况。 目前我这样做: 打印(“开始”) # 在这里做点什么 print("结束&q...

回答 1 投票 0

如何为asyncio.Task添加类型注释

我有一个代码,如下所示: 导入异步 从输入导入列表 def some_callback(结果): 打印(结果) 异步 def b() -> List[int]: 返回 [1, 2, 3] 异步 def a() -> N...

回答 1 投票 0

Python 3 asyncio 与 aioboto3 似乎是顺序的

我正在将一个简单的 python 3 脚本移植到 AWS Lambda。 该脚本很简单:它从十几个 S3 对象收集信息并返回结果。 该脚本使用 multiprocessing.Pool 来收集...

回答 2 投票 0

Asyncio Streams 服务器检测到断开连接

我正在使用 Streams 重写旧服务器,我从未解决的问题之一是断开连接问题。 我制作了这个非常简单的服务器示例: 导入异步 异步定义

回答 1 投票 0

如何使用 Asyncio 在单个 Python 应用程序中同时运行类的多个实例?

我试图在单个Python应用程序中同时运行一个类的多个实例,模拟让单独的终端独立运行每个类的效果。我的目标是......

回答 1 投票 0

当 IO 任务后跟 CPU 密集型任务时,python asyncio.gather 与 asyncio.as_completed

我的程序工作流程如下:1. IO-bound(网页获取)-> 2. cpu-bound(处理信息)-> 3. IO-bound(将结果写入数据库)。 我目前正在使用 aiohttp 来获取...

回答 2 投票 0

需要从同步实例方法调用异步实例方法

send_message() 从线程中调用。由于 my_channel.send() 是异步的,我认为有必要让同步 send_message() 调用异步 asend_message() 。如何做呢? #@

回答 1 投票 0

如何在asyncio.create_task()中调用asyncio.create_task()?

我一直在尝试使用 asyncio 同时运行 10 个不同的循环任务。所有 10 个任务在其循环中调用“asyncio.create_task()”。我不能使用“asyncio.run()”o...

回答 1 投票 0

如何使用 pytest 测试异步函数?

@pytest.fixture def d_service(): c = DService() 返回c # @pytest.mark.asyncio # 也尝试过 异步 def test_get_file_list(d_service): 文件=等待d_service.get_file_list('') p...

回答 3 投票 0

使用 asyncio.Queue 进行生产者-消费者流程

我对如何将 asyncio.Queue 用于特定的生产者-消费者模式感到困惑,在该模式中生产者和消费者同时且独立地操作。 首先,考虑这个例子,...

回答 1 投票 0

为什么 David Beazley 的演示中需要“future_monitor()” hack?

在 PyCon 2015 演讲中,为基于协同例程的斐波那契服务器提供了以下代码。添加 future_monitor() 是为了使服务器正常工作(否则会卡住)。但为什么是

回答 1 投票 0

导入 opcua xml 文件时出现错误

我使用siemens SiOME建模编辑器创建了testing_nodeset2.xml,所以首先我将opcua设备、opcua机械和opcua泵xml文件导入编辑器,然后创建自己的名称...

回答 2 投票 0

在循环中使用 Asyncio

我创建了一个程序,其中包含两个使用 asyncio 运行的主要异步函数: get_all_group_members():获取 Entra ID 组 ID 列表并返回该组的成员列表...

回答 1 投票 0

Scrapy + Playwright:从异步解析函数调用同步 parse_single 函数

我正在与 scrapy + Playwright 合作。 我目前拥有的蜘蛛的简化版本: 类 MySpider(CodeSpider): def start_requests(自身): url = 'https://www.google.com/search?q=p...

回答 1 投票 0

为什么在异步函数中使用httpx时线程不关闭?

我正在 jupyter 笔记本中运行 python 代码(3.10.14)。但是,当我在单元格中运行异步函数(AsyncClient.get(...) from httpx v0.27.0)时,我看到其中一个线程仍然是...

回答 1 投票 0

在Python中正确使用asyncio或多处理

我需要将一堆 .xlsx 文件转换为 PDF 文件。我使用 Linux mint,并且编写了一个脚本,如果按顺序完成处理,该脚本可以正确完成这项工作。然而这需要很多时间,我...

回答 1 投票 0

如何使用 Asyncio 避免错误 429(请求过多)python

我正在使用以下代码向 aiohttp 客户端发出请求。我尝试发送请求的服务器每个 IP 每小时有 30k 请求限制。所以我收到 429 请求过多错误。 ...

回答 1 投票 0

FastAPI:通过 Pickle 加载模型并进行预测。最好的方法是什么?

我正在构建一个 API,我需要通过 pickle 加载模型并进行预测 代码如下: 从 fastapi 导入 FastAPI 进口uvicorn 导入作业库 从实用程序导入 * # 上传...

回答 1 投票 0

异步Python - 使用命名管道与子进程进行双向通信

有一个关于使用命名管道从子进程读取和写入数据的问题。 我有一个 pygls 语言服务器作为主程序的子进程运行。 如果不是 os.path.exists(fifo_in_n...

回答 1 投票 0

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