我在我的一个项目中使用aiohttp，希望限制每秒请求的数量。我正在使用asyncio.Semaphore来做这件事。我的挑战是我可能想要增加/减少每秒允许的请求数。例如： limit = asyncio.Semaphore(10) async with aiohttp.request(...)
...await asyncio.sleep(1) 这很好用。也就是说，它将aiohtt
浏览 15提问于2021-01-21得票数 2
在Python中，使用异步异步/等待传递100 time调用的最佳方法是始终并行地使用100个任务？应该避免的是：
import asyncio
async with session.get(url) as response:
浏览 0提问于2019-06-10得票数 4
回答已采纳
我最近注意到在python的不同包中有两个不同的信号量实现，一个在threading包中，另一个在asyncio包中。我很好奇，这两种实现有什么区别？如果在异步函数中，我尝试使用threading包中的信号量，这会导致任何潜在的问题吗？通过查看python官方文档，它编写了
asyncio primitives are not thread-safe, therefore they should not be use
浏览 2提问于2021-10-24得票数 0
回答已采纳
我首先发出一个简单的请求，获取一个包含所有名称的JSON，然后遍历所有名称并进行与每个名称对应的异步可等待调用，并将它们存储在一个名为"tasks“的列表中，然后收集所有这些名称。问题是，响应服务器对每分钟的api响应有限制，并且无论我将信号量的值保持得多低，此代码都会花费相同的时间(小到不能满足服务器的期望)来进行API调用，就好像信号量根本不存在一样。如何控制API的
浏览 2提问于2021-06-15得票数 1
当我在Python3.7中运行此代码时： async with sem(work(), work(), work())
它在RuntimeError中失败了：workingTraceback/local/Library/Frameworks/
浏览 1提问于2019-04-30得票数 25
回答已采纳
在整个应用程序中，我都在使用asyncio。在应用程序中，启动了一个外部程序，但我希望将外部并发进程的最大数量限制为2，这就是为什么我使用Semaphore(2)的原因如下： proc =await asyncio.create_subprocess_shell(args)
sem = asyncio.Semaphore
浏览 5提问于2022-05-11得票数 0
1回答
作为Python新异步模块的一个实验，我创建了以下代码片段，以在后台工作人员中处理一组长期运行的操作(作业)。
为了控制同时运行的作业的数量，我在with块中引入了一个信号量(第56行)。但是，有了信号量，获得的锁似乎永远不会释放，因为在完成(执行回调)之后，等待的作业不会启动。当我丢弃with块时，一切都如预期的那样工作。self.limit_simultaneous_processes = asyncio
浏览 1提问于2015-02-10得票数 3
回答已采纳
我试图教会自己Python的异步功能。为此，我构建了一个异步web刮刀。我想限制我一次打开的连接的总数，以便成为服务器上的好公民。我知道信号量是一个很好的解决方案，异步库有一个内置的类。我的问题是，在将yield from和await语法组合在一起时，Python在async函数中使用yield时会发出抱怨。下面是我使用的确切语法..。import asyncio
s
浏览 3提问于2016-11-28得票数 20
使用Python3.10.6 (Fedora 35)运行，它的工作方式与教科书中的一样。21, in <module> File "/usr/lib/python3.8/asyncio/runners.py", line 44a different loop
导致错误的是async with sem行和Semaphore对象。没
浏览 16提问于2022-09-04得票数 5
回答已采纳
尝试使用信号量来控制异步请求来控制对目标主机的请求，但我得到了以下错误，我认为这意味着我的asycio.sleep()实际上并没有处于休眠状态。我该如何解决这个问题呢？我想为每个目标URL的请求添加延迟。()
File "/Library/Frameworks/Python.framework/Versions/3.7/lib/python3.7/asyncio/ba
浏览 170提问于2019-01-08得票数 21
回答已采纳
我有一个Python脚本，它使用asyncio发出超过一百万个请求。我首先遇到了内存问题，然后发现了信号量，此后我成功地实现了一个信号量，以限制并发任务的数量以及队列中的任务数量。_dns_result_callback, host)) await asyncio.gather(*self.tasks, return_exceptions=True)
在我实现信号量之前，程序会崩溃
浏览 1提问于2017-06-17得票数 2
允许my_function在一个http请求中发送列表是很容易的，但是asyncio.gather呢？也许其中一个itertools能帮上忙。(*tasks)
results = asyncio.run(main(rows))
TCP连接限制为500，因为REST web服务器可以接
浏览 1提问于2020-06-16得票数 3
回答已采纳
1回答
我想检查大约100个ips地址的可达性，并使用信号量设置并发任务的限制。但是现在我不知道它是如何工作的，或者为什么它在代码示例中不能工作。正如我所观察到的，"task_reachable“函数仍然正确执行。如果没有地址可访问，那么在"try_ssh_connection“中，所有”任务“都并行执行，这使得代码非常慢。self.password = "password"
self.ips = open("open_ip_list"
浏览 9提问于2022-03-22得票数 2
回答已采纳
我想创建可选的异步信号量。@contextlib.asynccontextmanager yield None
有没有默认的<
浏览 2提问于2020-04-28得票数 7
回答已采纳
1回答
我的脚本在应该异步运行时遇到错误
、、、、
我用python编写了一个脚本，使用asyncio与aiohttp库的关联来解析从异步表格中的不同机构信息中点击联系信息按钮时启动的弹出框中的名称。该网页跨513个页面显示表格内容。当我尝试使用asyncio.get_event_loop()时，我遇到了这个错误too many file descriptors in select()，但是当我遇到时，我可以看到有一个建议使用asyncio.ProactorEventLoop()
asy
浏览 5提问于2018-12-13得票数 1
回答已采纳
1回答
使用python3.4中的新异步，如何从一组锁/信号量中获取第一个锁/信号量？我所做的方法是使用wait(return_when=FIRST_COMPLETED)，然后一旦我设法获得一个acquire()，就会取消所有仍然挂起的acquire()。但我担心这可能会导致微妙的bug/种族条件，我觉得有一种更优雅的方法。)：
initial: <asyncio.locks.Semaphore objec
浏览 4提问于2014-08-17得票数 6
回答已采纳
我想使用一个带有use ()的信号量来限制api调用。以下是代码：# pip install git+https://github.com/sammchardy/python-binance.git@00dc9a978590e79d4aa02e6c75106a3632990e8dfrom binance import AsyncClient
tas
浏览 6提问于2020-05-13得票数 9
回答已采纳
1回答
问题是，我想要获得我在阈值之前完成的(会话中的部分)响应，因此，例如，如果会话包含10个请求，而在超时之前，我已经完成了其中5个请求，我想获取这5个请求的结果。但我还没有想出如何做到这一点。我使用的代码是这样的：import asyncio async with session.getn, timeout):
async with aiohttp.Clie
浏览 3提问于2020-01-23得票数 2
回答已采纳
1回答
信号量值大于初始化值
、、、、
我正在Linux中开发信号量。我想知道信号量值是否可以在初始化值之外增加？如果是的话，什么时候会发生这种情况？
例如，信号量值被初始化为1。如果我连续两次递增up(sem)，信号量的值会增加超过1吗？
浏览 6提问于2015-04-02得票数 1
回答已采纳
1回答
() self.queue.put_nowait_get() return get_task = asyncio.e
浏览 13提问于2019-12-12得票数 1
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
