python-asyncio 相关问题

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

运行时错误:无法从正在运行的事件循环调用 asyncio.run()

我正在 asyncio 上运行最简单的示例: 导入异步 异步 def main(): 打印(“A”) 等待 asyncio.sleep.sleep(1) 打印(“B”) asyncio.run(主()) 我明白了...

回答 2 投票 0

具有异步方法的流畅模式

这个类有异步和同步方法(即 isHuman): 班级人物: def isHuman(self) -> 自我: 如果是自我.人类: 返回自我 引发异常(f'{self.name} 不是人类') 异步...

回答 2 投票 0

python numpy支持asyncio吗

我需要将包含 numpy 方法的同步代码移至异步代码。我试图找到它的文档,但一无所获。 我使用的方法是: 大批 日期时间64 在哪里 该过程会继续吗...

回答 1 投票 0

与队列的异步多处理通信 - 仅一个协程运行

我有一个管理器脚本,它启动一些进程,然后使用两个协程(一个用于监视,一个用于收集结果)。由于某种原因,似乎只有一个协程在运行,我错过了什么? (我...

回答 1 投票 0

TeleBot:“对象 NoneType 不能在‘await’表达式中使用”

Всем привет。 Ниже обработчик системных сообщений от ТГ 和 если пользователь вступил в чат или вышел - бот пишет сообщение。 导入远程机器人,配置 bot = telebot.TeleBot(config.Token) @bot.message_ha...

回答 1 投票 0

如何在失败的情况下终止Python中的异步进程

我正在使用 asyncio 异步启动一个进程,然后从 stdout 读取数据,我的代码如下所示: 进程 = 等待 asyncio.subprocess.create_subprocess_exe(subprocess_args,

回答 1 投票 0

属性错误:异步 SQLalchemy 会话中的 __aenter__

使用会话时出现 AttributeError: __aenter__ 错误,如下所示: 异步 def get_session(): SessionLocal = sessionmaker( 自动提交=假, 自动刷新=假, ...

回答 1 投票 0

从协程中提取函数和参数

python3.6中是否可以提取协程对象的函数和参数? 上下文:目前我有这样的事情: 异步 def func(*args): ... ret = 远程等待(func, ...

回答 3 投票 0

在内部,asyncio run_forever() 基本上是一个 while True 循环吗?

python asyncio run_forever 或 while True 类似,但它是一个“我应该这样做......”的问题。 我更想了解 python asyncio 的内部结构是否基本上是 而真实...

回答 1 投票 0

Python Asyncio 并发问题:GPT4 连续函数调用中的混合响应

我遇到了一个令人困惑的 asyncio 问题,在短时间内连续运行我的函数会导致混合响应。该函数向 AI 服务发送提示和数据

回答 1 投票 0

Flask:如何在完整路由代码执行之前返回验证

抱歉新手问题 - 我是 Python 新手。 我必须在主代码执行之前返回 Flask 路由参数的验证结果: @app.route('/', 方法=['POST']) 定义索引(): 验证=

回答 1 投票 0

如何运行多个websocket客户端连接?

我有一个 Django 服务(我们称之为“主”服务),它运行一个 HTTP 服务器和一个使用 django-channels 的 WebSocket 服务器。我还有很多其他 django 服务(称它们为 ta...

回答 1 投票 0

asyncio.TaskGroup 中的键盘中断

任务组的文档说: 特殊处理两个基本异常:如果任何任务因 KeyboardInterrupt 或 SystemExit 失败,任务组仍然取消剩余任务并等待它们,...

回答 1 投票 0

Python 中使用 `asyncio` 进行多个请求

我正在尝试同时提出多个请求。 我是Python中的async和await新手(我在Js中使用过它)。 我找到了一个例子并使用了这个: 导入异步 导入 aiohttp 异步 def get_i...

回答 1 投票 0

在aiobotocore中重用create_client以获得更好的性能

我正在实现一个异步Python代码,它使用aiobotocore将对象放入S3中。 代码是这样的 - 类 Foo: def __init__(自身): self._aiobotocore_session = get_sessi...

回答 1 投票 0

验证 python asyncio 异步运行

我有一个函数,它接受 html 字符串,通过删除停用词来清理它,然后计算用户确定的搜索字符串中单词出现的次数: def clean_text(字符串,

回答 1 投票 0

Python 3.7.4 和 3.10.6 asyncio 在 VS Code 调试调用堆栈中创建多个任务

在使用 asyncio 和 aiohttp 时,遇到了这个问题,想知道这是否仅限于 VSC 发生? 这个循环会留下前一个循环的残留物。 而真实: 循环。

回答 2 投票 0

AWS Lambda FastAPI Firehose 问题[重复]

我有一个在 AWS Lambda 上运行的简单 FastAPI REST 服务器。它使用 AWS Kinesis Firehose 将日志写入 S3。我从异步单个 Firehose 写入开始,速度非常慢。然后我想出了一个

回答 1 投票 0

从 API 异步获取数据时,Asyncio 锁不起作用

我的以下功能未按预期运行。它是一个异步函数,我希望它能够在响应为 401 并且锁未锁定时删除 api_keys 中的第一个值。当...

回答 1 投票 0

如何将 HTTP 请求从我的 FastAPI 应用程序发送到另一个站点 (API)?

我尝试使用以下代码片段一次向服务器 http://httpbin.org/uuid 发送 100 个请求 从 fastapi 导入 FastAPI 从时间导入睡眠 从导入时间开始 进口需求...

回答 3 投票 0

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