python-asyncio 相关问题

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

如何用Python从数百个URL请求数据?

我正在使用 REST API 来提取一些数据。 我有一个大约 10k url 的列表,我可以 ping 来获取我们需要的数据。 所以,这段代码有效: 结果={} 对于 url 中的 url: 结果[url] = requests.get(url).json()

回答 3 投票 0

用于异步和同步功能的 Python 装饰器,无需重复代码

我至少见过两个装饰器的例子,它们可以与普通的 defsync_func() 和 async def async_function() 一起使用。 但所有这些示例基本上都重复了这样的装饰器代码 小鬼...

回答 1 投票 0

python 的 influxdb-client 不采用自定义时间戳

我是 InfluxDB 的新手,一直在尝试通过 influxdb-client == 1.36.1 将具有多个具有自定义时间戳的字段的数据点从字典存储到 influxdb 中 我关注了 pypi

回答 1 投票 0

等待 asyncio.create_task 在 Spyder IDE 中获取结果

我试图了解如何使用 Spyder IDE 在 python 中运行异步调用。 我编写了以下代码: 导入异步 从并发.futures 导入 ThreadPoolExecutor 事实上异步...

回答 1 投票 0

在 python-telegram-bot 中使用 asyncio 和线程

并发限制= 3 信号量 = asyncio.Semaphore(concurrency_limit) 异步 def send_pdf(last_update: 更新,上下文: ContextTypes.DEFAULT_TYPE): 与信号量异步: 聊天 ID =

回答 1 投票 0

对多个 HTTP 请求进行异步状态检查

我有一个列表,其中包含数千个指向远程服务器上的图像/视频的 URL。就像是: urls = ['https://foo.bar/baz.jpeg', 'https://foo.bar/jaz.mp4', ...] 通过获取那些你的...

回答 2 投票 0

如何在Python/FastAPI中获取事件循环的所有待处理任务?

我正在尝试了解我的 FastAPI 应用程序中潜在的速度下降问题。 我的理解是,每次我执行等待时,都会安排一个任务稍后执行,从而创建要执行的积压任务。如果...

回答 1 投票 0

类型错误:“协程”对象不支持异步上下文管理器协议

我正在尝试创建邀请经理,但不断收到此错误 异步与cursor.execute(“SELECT id,使用FROM邀请WHERE guild_id = ?”,(member.guild.id,))作为光标: 运行时警告...

回答 1 投票 0

并行运行函数

我正在用系统时钟模拟CPU。我目前使用 asyncio 设置它的方式是 Clock.run() 函数有一个无限循环并等待一段时间然后触发一个事件然后等待...

回答 1 投票 0

Python ThreadPoolExecutor(max_workers=MAX_PARALLEL_REQUESTS) 异步模拟

当我使用 ThreadPoolExecutor 时,我可以发送批量请求,但限制并行请求,如下所示: 使用 ThreadPoolExecutor(max_workers=MAX_PARALLEL_REQUESTS) 作为池: 结果=列表(便便...

回答 1 投票 0

为 Python 的 `websockets` `serve` 函数传递附加参数

我正在使用 Python 的 websockets 库构建 WebSocket 服务器原型。 async def receive_websocket_message(websocket, send_queue: asyncio.Queue, receive_queue: asyncio.Queue): 消息异步...

回答 1 投票 0

Python 异步协程是同步运行的吗?

我正在尝试了解更多有关 asyncio 内部结构的信息。从文档来看,异步函数似乎是程序指向的机制,可以使代码的阻塞部分乱序执行......

回答 1 投票 0

为什么threading.Condition.notfiy_all没有触发等待线程继续?

通过下面的代码,我想展示如何与线程同步。 我想要一个单独的线程来更新图像。 从这些图像中,我想要一个异步生成器。 我...

回答 1 投票 0

运行嵌入在线程中的异步事件循环

我有一个 Qt 应用程序,它使用 pybind 嵌入提供某种处理程序的 python 插件。根据我在网上阅读的内容,粘合事件循环几乎是不可能的。现在我想知道是不是...

回答 1 投票 0

使用“asyncio.Queue”和“TaskGroup”在“pytest”期间执行挂起或死锁

我是异步编程新手,我试图了解如何将 TaskGroup 与 asyncio.Queue 一起使用。我有以下带有测试的模块,但是在执行 pytest 时,它打印出队列项,但是...

回答 1 投票 0

在 IPython 8.22.1 / Python 3.11 上设置事件循环失败

以下反应正常还是我的Python安装有问题。从我刚刚阅读的几个小时来看,它确实应该有效。否则我做错了什么? Python 3.11.6(主要...

回答 1 投票 0

Aiohttp / 阻塞send_str方法

我对 asyncio 和 aiohttp 有一点理解问题。 看看我的代码,我期望出现以下情况: Asyncio Gather() 首先以 funk1 开头。打印“a”并购买...

回答 1 投票 0

如何修复运行时错误:无法关闭正在运行的事件循环 - Python Discord Bot

我正在尝试使用 Python 创建一个 Discord 机器人,但是每当我运行此处的示例代码时: 导入不和谐 客户端=不和谐.Client() @client.event 异步定义 on_message(消息): #我们不...

回答 3 投票 0

具有多线程的协程

所以我一直在尝试制作这个使用yolov8对象检测模型进行推理的discord机器人。我在 on_message 事件中运行推理函数,但由于它的阻塞性质,...

回答 1 投票 0

无法关闭正在运行的事件循环,当我调用 run_forever 时我无法关闭循环

当我停止websocket线程时,我也需要停止循环线程,但是当我调用loop.stop()和loop.close()时,出现了一些问题,我无法关闭循环,请附加一些问题帮助我,接下来我...

回答 4 投票 0

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