python-asyncio 相关问题

如何同时运行具有异步函数的类的多个实例？

类计算(): def __init__(自身, 值): 自我价值=价值 异步定义一个（自身）： 而真实： print(自身值 * 1) 等待 asyncio.sleep(1)

为什么使用 asyncio for 循环的代码不比同步代码快？

我正在从 O'Reilly 出版的一本名为“Using Asyncio in Python”的书中学习 Python asyncio。 本书中有一个 async for 循环的示例： # 例 3-26.使用异步生成器更容易...

python asyncio for 循环

嗨，我正在从 o'reilly 的《Using Asyncio in python》一书中学习 python asyncio 本书中有一个异步 for 循环的示例 # 例 3-26.使用异步生成器更容易 导入...

Python 3.12.3 Quart Hypercorn ASGI 框架运行时错误错误：没有运行事件循环

我使用以下命令运行 quart hypercorn 服务器： pipelinev 运行 hypercorn --config=hypercorn.toml --reload src.main:app 以及以下配置： accesslog =“/var/log/pythonrest...

如何在 Telethon 中正确使用上下文变量？

我正在使用 Telethon 库开发一个 Telegram 机器人。 我想将tags_cv的值从send_tag_list()传递到show_selected_tags()。但我收到这个错误： `错误 -

为什么调用 `await asyncio.sleep` 会运行未等待的任务，但 `time.sleep` 不会运行？

我有这个代码片段 导入异步 导入时间 async def put_stuff_into_queue(stuff_into_queue: list[str],queue: asyncio.Queue) -> None: 对于 stuff_into_queue 中的内容： 等待q...

为什么调用 `await asyncio.sleep` 会运行未等待的任务，但 time.sleep 却不会？

我有这个代码片段 导入异步 导入时间 async def put_stuff_into_queue(stuff_into_queue: list[str],queue: asyncio.Queue) -> None: 对于 stuff_into_queue 中的内容： 等待q...

在 aiohttp.ClientSession.get() 中接收“运行时错误：会话已关闭”，即使在创建新的上下文管理器之后也是如此

我正在使用 aiohttp 编写一个网络爬虫，并且我的程序因网络爬虫中的“运行时错误：会话已关闭”错误而崩溃。 主循环完成第一次迭代，获取...

Python asyncio.gather 不是真正并行的？

所以我试图理解 asyncio.gather() 函数中的并行性。 我有一个 FastAPI 应用程序，需要同时上传 4 个文件到 s3。 我现在正在使用本地 S3 进行测试，所以

导致异步代码停止工作的原因 - Pyrogram

运行几个小时后。我的机器人总是会停止工作。我总是必须重新启动容器才能使其恢复工作。我只需要找出真正导致机器人停止的原因

Scrapy 芹菜

如何在我的任务中以 2 分钟的间隔按顺序（一个接一个）运行蜘蛛？ 信号.py @receiver(post_save, 发件人=ParseCategoryUrl) def start_parse_from_category_url(发件人, 创建,

替换已弃用的 asyncio.get_event_loop()

我正在升级的脚本使用 asyncio.get_event_loop()，该脚本自 Python 3.12 起已弃用。 Asyncio 文档建议使用 asyncio.get_running_loop()，它被认为更稳定，因为...

何时使用 asyncio.get_running_loop() 与 asyncio.get_event_loop()？

我见过使用运行阻塞代码 循环 = asyncio.get_running_loop() 等待loop.run_in_executor（无，blockingfunc） 和 循环 = asyncio.get_event_loop() 等待循环.run_in_executor（无，

将异步生成器转换为同步生成器

想象一下我们有一个原始的API，它返回一个生成器（它实际上是一种从服务器带来页面/结果块的机制，同时向用户提供一个简单的生成器，并让他

Asyncio：批处理队列处理器

我正在尝试使用 asyncio 构建一个批处理队列处理器。它应该工作的方式是，人们应该能够将单个请求推入队列，并且队列处理器将批处理......

使用多处理和异步的 TTS 服务中的 WebSocket 意外关闭

我正在Python中使用多处理和异步开发TTS（文本转语音）服务。我的主要应用程序使用队列集成其他组件。 但是，我遇到了一个问题，其中

python 协程和 while 循环，如何运行两者

我正在尝试一起运行两个协程并使用异步，一个是 teleton 电报客户端，一个异步任务每分钟为电报机器人获取数据。一些代码： 从 asyncio 导入 Runner 来自

如何使用 Django/Django-Ninja 检测 StreamingHttpResponse（服务器端事件）上的客户端断开连接？

我们想要在应用程序中添加服务器端事件，但目前 while True 循环无限期地运行，并且客户端断开连接不会导致任务停止。 可重现的例子： @api.get("/

asyncio：从执行器中的异步函数收集结果

我想启动大量 HTTP 请求并在所有请求返回后收集它们的结果。使用 asyncio 可以以非阻塞方式发送请求，但我有

在收集所谓“已取消”的任务时遇到递归深度错误

我一直在尝试理解Python中的异步编程。现在我有了这个简单的代码，它模拟了我正在处理的代码。 类示例： def __init__(自身): self.loop = 异步。