我希望asyncio.gather立即引发除某些特定异常类之外的任何异常，这些异常类应该在结果列表中返回。现在，我只是稍微修改了CPython中asyncio.gather的规范实现，并使用了它，但我想知道是否有更规范的方法来实现它。
浏览 10提问于2018-02-17得票数 2
回答已采纳
1回答
我对asyncio.gather进行了如下实验： """Do some上做一个包装器：def in_parallel(*aws, loop=None, return_exceptions=False):return asyncio.gather(aws, loop, return_exceptions
浏览 4提问于2020-04-03得票数 1
回答已采纳
1回答
我已经创建了我所面临的问题的示例，其中我的异步函数如下所示： try: raise E # Does not raise exception :( async def main():
await asyncio.gather(async_fun("baz"), return_exc
浏览 4提问于2021-03-03得票数 1
回答已采纳
当使用asyncio.gather时，当其中一个任务引发异常时，不会执行所有任务：import asyncio
awaitasync def main(): for i in range(1000): await asyncio.gatherinput>", line 21, in main
File "<input>&quo
浏览 4提问于2021-03-24得票数 1
回答已采纳
我非常喜欢logging.exception()返回的信息，但是这个函数只能在异常处理程序中使用。现在，运行asyncio.gather(..., return_exceptions=True)不会引发异常，而是将异常作为Exception对象返回。我想用与Exceptions相同的详细信息来记录这些logging.exception()对象，但是由于我不是在一个异常处理程序中，我如何做到这一点？
浏览 31提问于2022-01-04得票数 0
回答已采纳
我的函数run_tasks(all_tasks, window_size)，它接受任务的生成器并返回它们的值，同时：
import asyncio
#all_tasks = (sleepy(i) for i in range(10
浏览 4提问于2017-09-02得票数 2
回答已采纳
我试图优化一个简单的网页刮刀，我做了。它从主页上的表中获取urls列表，然后转到每个“子”urls，并从这些页面获取信息。我甚至尝试运行它的同步版本，并得到相同的错误。我认为远程服务器阻止了我的请求，但是，--我可以运行我的原始程序--并且可以从同一个IP地址访问每个urls，而不需要发出。tasks.append(asyncio.ensure_future(get_response(client, url))) detail_responses
浏览 23提问于2022-02-16得票数 6
1回答
我想点击api大概几千次，但是我不知道如何处理下面的示例中的错误。如果我想停止处理，这是怎么做到的？是否对每个put请求有任何控制？ results = await asyncio.gather
浏览 7提问于2022-11-09得票数 0
我有一个用Sqlalchemy在Postgresql中创建对象的API，我想通过JSON文件发送请求并检查API中的很多请求，我没有任何错误，但是有两个问题: 1-异步不能工作2-响应时间太长，请检查我的代码好吗objects = json.loads(contents) results = await asyncio.gather(*[create(urls,session, row)], return_excepti
浏览 1提问于2022-07-25得票数 0
回答已采纳
例如，asyncio.gather有签名asyncio.gather(*coros_or_futures, loop=None, return_exceptions=False)。我可以传递特定的循环或离开None (默认事件循环将被使用)。为什么BaseEventLoop.run_in_executor的定义不一样，比如：asyncio.run_in_executor(executor, callback, *args, loop=None)
如果有什么重要的理由把它放入BaseEve
浏览 2提问于2015-07-02得票数 1
回答已采纳
下面是捕获由一个任务传播的异常并为这两个任务重新启动集合的适当方式吗？footask = asyncio.create_task(foo()) bothtasks = asyncio.gather因此，由于我想不出更好的方法，我用task.cancel()手动取消了其他任务，并亲自处理asyncio.CancelledError。在
浏览 2提问于2018-12-24得票数 0
该方案应做的工作概述：步骤2(同步)：创建指向要在for-循环中刮取的页面的链接。步骤3(异步)：使用步骤2中的链接列表从每个页面获取到所需详细信息页的链接。我的问题在哪里？
从步骤3到步骤4的转换似乎不能正常工作。True添加到p
浏览 6提问于2022-12-01得票数 0
回答已采纳
1回答
我从另一个模块调用async_provider()函数，并使用生成的response.text()执行后续任务。只有当所有请求都成功时，它才起作用。但是对于失败的请求，我不能处理任何异常(无论异常的原因是什么)。谢谢你的帮助。以下是代码的相关部分： import asynciodef async_providerreturn await response.text()
async d
浏览 22提问于2019-08-23得票数 0
回答已采纳
下面的代码失败了，我无法获得实际的错误，我只收到了大量的CancelledError消息 response = await client.batch_write_item(RequestItems=item)
asyncio.gatherretrieved
future: <_GatheringFuture finished exceptio
浏览 0提问于2019-05-08得票数 2
回答已采纳
也许其他人能看到我可悲地看不到的东西。request_queueCreate 打开新会话，创建一个用于处理API请求的队列和一个用于API响应的第二个队列。(*api_workers, return_exceptions=True) return profiles
5() for request_workers有参数return_exceptions=True，它为每个工人处理Ca
浏览 8提问于2022-01-13得票数 0
1回答
在异步集合中捕获异常
、、、
task_list = [task1(), task2(), task3()]关于文件如果return_exceptions为True，则异常将与成功的结果相同，并在结果列表中进行聚合。
浏览 0提问于2021-01-05得票数 3
回答已采纳
2回答
习惯性地从一个期货字典中收集结果
、、、、
我正在尝试写一些尽可能地道的东西，以便从存储在字典中的期货中收集结果。sleeping 3 seconds{'4': None, '3': None, '2': None, '1': None}async def gather_from_dict(tasks:Dict[Hashable, Awaitable],
浏览 1提问于2018-01-08得票数 21
我从作者caleb hattingh的书中摘取了下面的代码片段。我试着运行代码片段并面临这个错误。for i in range(10):pending = asyncio.all_tasks()results = loop.run_until_complete(group)
print(f'Results:
浏览 13提问于2022-01-27得票数 3
回答已采纳
', flush=True )
final_task = asyncio.gather(loop)
#get_title_range
浏览 26提问于2021-02-23得票数 0
我已经使用asyncio编写了我的脚本，但是我发现同时运行的协程的数量太大了，而且它经常会挂起。loop = asyncio.get_event_loop()result = loop.run_until_complete(asyncio.gather(*p))
async def my_func(player
浏览 2提问于2018-05-13得票数 20
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
腾讯云开发者
