python-asyncio 相关问题

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

Python 包 - aiohttp 有警告消息“未关闭的客户端会话”

我的代码如下: 导入异步 导入 aiohttp 网址 = [ 'http://www.163.com/', 'http://www.sina.com.cn/', ] 异步 def get_url_data(u): resp = 等待 aiohttp.ClientSession().get(u...

回答 3 投票 0

`await asyncio.sleep(0)` 与 `loop.run_in_executor()` 不并发

awaitloop.run_in_executor(executor, open_read) 不会返回,直到await asyncio.shield(get_audio_async(sentence)) 产生对事件循环的控制。我将await asyncio.sleep(0) 调用放入no ...

回答 1 投票 0

如何将控制权交还给事件循环

导入异步 异步 def long_running_task(): 尝试: 而真实: # 你的长时间运行的处理 如果 asyncio.current_task().cancelled(): 引发异步。

回答 1 投票 0

Socket 阻塞其他功能 RPi pico

我正在制作一件艺术品。它由多个树莓派 picos 组成。使用 micropython 进行编码。 有一个基于 RPi pico 的远程控制,其作用类似于 Web 服务器,提供

回答 1 投票 0

FastAPI、SQLAlchemy、asyncio,此会话正在配置新连接;不允许并发操作

连接.py 从输入 import AsyncIterable 从 sqlalchemy.ext.asyncio 导入 AsyncSession、async_sessionmaker、create_async_engine 从 sqlalchemy 导入 NullPool SessionFactoryType =

回答 1 投票 0

为什么我无法使用 aiohttp 发出 get-request:期望值:第 1 行第 1 列(字符 0)?

为什么我看到错误 向以下位置发出请求时出错 https://data.similarweb.com/api/v1/data?domain=httpbin.org:期待 值:第 1 行第 1 列(字符 0) 使用 aiohttp 而 requests.get 返回

回答 1 投票 0

异步下载多个azure blob

我正在尝试提高从 Azure 下载 blob 的速度。使用 azure 中的包示例,我创建了自己的示例。但是,它仅适用于单个文件。我希望能够...

回答 1 投票 0

使用 asyncio.run 和装饰器

我使用pyrogram,需要将asyncio.run与装饰器一起使用; 就像是: @app.on_message() 异步defreply_on_message(客户端,消息): print("装饰器正在工作") 异步定义...

回答 1 投票 0

同时保存到csv opcua数据更改通知

我同时订阅了多个节点,这样我只有在值发生变化时才会收到通知。我需要将数据存储在 csv 文件中,并使用时间戳 + 所有值写入行...

回答 1 投票 0

在 Flask 应用程序后台运行异步 Websocket 循环

我正在尝试构建一个应用程序,它将连接到 websocket(用于流数据)并通过 REST API 提供此数据。我正在使用 Flask 创建 API 和 websockets 包来连接到

回答 1 投票 0

SQLAlchemy 和 asyncpg 错误:asyncpg.exceptions.ConnectionDoesNotExistError:连接在操作过程中关闭

我已经制作了我的第一个电报机器人。使用 Python 3.12、asyncio、asyncpg (0.29.0) 和 ASQLAlcemy (2.0.29) 我尝试在 1 个表中创建 1 列,但收到错误 'asyncpg.exceptions.ConnectionDoesNotExistError:

回答 1 投票 0

在 Pydantic 自定义验证器中调用异步函数

我有 2 个 Paydantic 模型文章和作者定义如下: 从 pydantic 导入 BaseModel 从输入导入列表 类作者(BaseModel): id:整数 名字:str 类文章(BaseM...

回答 1 投票 0

在pycharm调试器中调试异步程序

我的要求是从调试器和pycharm提示符中获取调试数据: 假设我有一个旧式的 python 同步程序,有一个错误: def listdir(self, 远程路径): 使用 ssh。

回答 2 投票 0

Python中的asyncio是用户级线程模型,协作调度吗?

我已经在 Python 中使用 asyncio 工作了很长时间,但是我想澄清一些关于 asyncio 实际工作原理的想法。我会分解我的想法,以便我可以提供背景信息并......

回答 1 投票 0

为什么会失败并显示“'async for'需要一个带有 __aiter__ 方法的对象,得到协程”

我正在尝试使用异步客户端库(该库也由 Google 提供)调用外部 API(由 Google 提供)。 我尝试调用的异步方法是 async

回答 1 投票 0

异步FastAPI为什么授权中有同步代码?

大家好) 为什么授权有一个用于创建和检查密码的同步库? 这是文档中的代码: def verify_password(plain_password, hashed_password):...

回答 1 投票 0

Asyncio StreamReader 偶尔读取 0 字节

我有一个简单的流读取器,它正在监听 TCP 端口以实现 Websocket。该流偶尔会读取(每 30-300 秒)空白数据并引发错误。 循环=异步。

回答 1 投票 0

Pytest 两个带有无限循环和等待命令的异步函数

我正在对Python代码进行单元测试。它有一个异步循环。该循环中的两个主要函数都有无限的 while 循环。我已经测试了代码的非异步部分。我想知道什么是最好的

回答 1 投票 0

无法从另一个函数取消asyncio.task

我本来希望使用cancel函数取消foo_wrapper,但是,它仍然生成结果。 如果我将 foo_wrapper 更改为非异步函数并将 self.lock 更改为 threading.Lock 可以解决问题...

回答 1 投票 0

AIO 文件 VS AIO 文件

我想从异步进程打开文件,我注意到可以使用两个不同的模块:aiofiles 和 aiofile。但是,我似乎没有找到有关两者之间优缺点的信息...

回答 2 投票 0

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