此标记用于asyncio Python包,它提供了编写单线程并发代码的机制。 asyncio包提供从Python 3.4开始的异步I / O,事件循环,协同程序和任务。
在 Flask 应用程序后台运行异步 Websocket 循环
我正在尝试构建一个应用程序,它将连接到 websocket(用于流数据)并通过 REST API 提供此数据。我正在使用 Flask 创建 API 和 websockets 包来连接到
SQLAlchemy 和 asyncpg 错误:asyncpg.exceptions.ConnectionDoesNotExistError:连接在操作过程中关闭
我已经制作了我的第一个电报机器人。使用 Python 3.12、asyncio、asyncpg (0.29.0) 和 ASQLAlcemy (2.0.29) 我尝试在 1 个表中创建 1 列,但收到错误 'asyncpg.exceptions.ConnectionDoesNotExistError:
我有 2 个 Paydantic 模型文章和作者定义如下: 从 pydantic 导入 BaseModel 从输入导入列表 类作者(BaseModel): id:整数 名字:str 类文章(BaseM...
我的要求是从调试器和pycharm提示符中获取调试数据: 假设我有一个旧式的 python 同步程序,有一个错误: def listdir(self, 远程路径): 使用 ssh。
Python中的asyncio是用户级线程模型,协作调度吗?
我已经在 Python 中使用 asyncio 工作了很长时间,但是我想澄清一些关于 asyncio 实际工作原理的想法。我会分解我的想法,以便我可以提供背景信息并......
为什么会失败并显示“'async for'需要一个带有 __aiter__ 方法的对象,得到协程”
我正在尝试使用异步客户端库(该库也由 Google 提供)调用外部 API(由 Google 提供)。 我尝试调用的异步方法是 async
大家好) 为什么授权有一个用于创建和检查密码的同步库? 这是文档中的代码: def verify_password(plain_password, hashed_password):...
Asyncio StreamReader 偶尔读取 0 字节
我有一个简单的流读取器,它正在监听 TCP 端口以实现 Websocket。该流偶尔会读取(每 30-300 秒)空白数据并引发错误。 循环=异步。
我正在对Python代码进行单元测试。它有一个异步循环。该循环中的两个主要函数都有无限的 while 循环。我已经测试了代码的非异步部分。我想知道什么是最好的
我本来希望使用cancel函数取消foo_wrapper,但是,它仍然生成结果。 如果我将 foo_wrapper 更改为非异步函数并将 self.lock 更改为 threading.Lock 可以解决问题...
我想从异步进程打开文件,我注意到可以使用两个不同的模块:aiofiles 和 aiofile。但是,我似乎没有找到有关两者之间优缺点的信息...
我的情况很独特。我正在创建一个通用代码实用程序,我的任务是通过异步 API 调用来提高性能。大多数程序都有 6 到 10 个相同的 API 调用来读取
为 OPC UA python 服务器/客户端(Asyncua)添加安全性
我是 OPC UA 和 Python 的新手,但通过 asyncua 示例,我创建了实际项目所需的示例。现在我需要为服务器和客户端添加安全性,现在使用用户名......
我正在尝试并行化在我的 ORM 挂钩之一中完成的一些工作。每当创建或修改模型时,我都想调用第三方系统来反映该更新。这个电话,...
下面的示例类有一个可等待的属性栏,如 async_main() 中一样,因为它(理论上)在返回所有内容的答案之前执行一些 IO 工作。 类 Foo: @财产
我正在使用 python-telegram-bot 开发一个电报机器人。它就像一个股票筛选器,它会在每个给定的时间间隔分析市场并将结果发送给订阅该指标的用户......
我正在尝试设置一个异步程序,该程序将一个 AsyncGenerator 作为输入,并通过另一个 AsyncGenerator 返回数据。下面是一个示例程序,说明了基本的数据流: 来自
在Python中使用asyncio时如何测量阻塞代码所花费的时间?
我目前正在迁移一些曾经阻塞的 Python 代码,以将 asyncio 与 async/await 结合使用。一次需要迁移很多代码,所以我更喜欢逐步迁移并有指标。与...
我有一个异步脚本,它将 1 个请求发送到不同的 url(本例中为 223),因此不是同一主机。问题是,在大约 150 个请求之后,它开始超时 url,但在处理时......
如何停止使用 websockets.serve() 创建的 websocket 服务器?
我使用此包创建了 websocket 服务器 https://websockets.readthedocs.io/en/stable/intro.html。我必须停止在运行时重新启动该服务器。 我的服务器作为 asyncio.Task 运行,但取消()我...