腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Asyncio
:
异常
发生
时
等待
任务
完成
、
、
、
、
#in order to process it again I put it in different queue await queue_retry.put(msg) 但是,
等待
在更新队列之前
完成
吗?如果没有,我不知道它会放入什么msg,我怀疑它不会
等待
新的 它会把旧的放在。
浏览 33
提问于2021-01-30
得票数 2
回答已采纳
1
回答
带有aiohttp异步请求的
任务
异常
、
、
批处理()函数中面临的问题是,一些请求正在记录下面的消息,尽管脚本仍在继续,而且不会失败,但im无法捕获并记录此
异常
,以便稍后重新处理它们。_loop.create_connection(*args, **kwargs)) raise exceptions[0] File "C:\Miniconda3\lib\
asyncio
\base_e
浏览 0
提问于2019-05-03
得票数 3
1
回答
使用异步创建和处理条件
、
到目前为止,我可以通过在任何失败的测试中抛出
异常
来处理它。test2(data): finished, unfinished = ioloop.run_until_complete(
asyncio<
浏览 1
提问于2018-04-08
得票数 0
回答已采纳
1
回答
asyncio
.wait返回
异常
,即使在“尝试.除了`
、
、
、
、
我在不和谐的机器人中有一个
asyncio
.wait语句,所以我可以一次
等待
多个事件。这样,机器人就不会随着时间的推移而陷入困境,我对这两个
等待
语句都有一个超时时间。('reaction_remove', timeout=30, check=check)] done_tasks, pending_tasks = await
asyncio
.wait(pending_tasks, return_when=
asyncio
.FIRST_COMPLETED
浏览 2
提问于2020-06-26
得票数 0
回答已采纳
1
回答
什么时候使用await和
asyncio
.create_task()?
、
、
假设我有一个发布者发布消息,一个消费者使用它并调用数据库保存方法,那么我应该使用哪一个或为什么呢?
浏览 2
提问于2020-09-05
得票数 1
1
回答
Asyncio
和aiohttp将请求
、
、
import aiohttp import time results = await
asyncio
.gather(*tasks) # Is this after execution and
浏览 7
提问于2022-11-09
得票数 0
1
回答
如何优雅地关闭与Ctrl+C的合作?
、
、
在
完成
所有的工作之后,这个程序就可以很好地关闭。源代码可以在python3.5中运行,如下所示。import
asyncio
from contextlib import suppress def __init__(self): self.task_queue =
asyncio
.Queue(self.max_tasks) self.loop=
asyncio</e
浏览 3
提问于2017-08-03
得票数 5
回答已采纳
1
回答
在python
asyncio
.Task中直到主
任务
完成
后才引发
异常
、
然而,当主要
任务
coro2
完成
时
,它
等待
了10秒。import
asyncio
def coro1(): yielddef coro2(loop): print("coro2 primed&qu
浏览 1
提问于2020-12-19
得票数 0
回答已采纳
2
回答
在多个消费者之间共享一个动态启动的工作人员
、
目标是只在一个或多个使用者需要连接
时
维护连接。 pass pass场景1 -启动
时
的
异常
员工启动序列会引发
异常
。 两个使用者都应该将
异常
看作是他们调用start()的结果
浏览 0
提问于2018-11-08
得票数 2
回答已采纳
1
回答
如何确保使用
asyncio
.gather执行所有
任务
?
、
当使用
asyncio
.gather
时
,当其中一个
任务
引发
异常
时
,不会执行所有
任务
:import
asyncio
await
asyncio
.sleep(0.1) print("2: 1/0") print(i)
浏览 4
提问于2021-03-24
得票数 1
回答已采纳
1
回答
等待
子
任务
在外部
任务
完成
事件上
完成
(异步版本的add_done_callback)
、
、
假设我们有一些
任务
(子
任务
)在外部
任务
完成
时
应该
完成
。我们无法控制外部
任务
:我们不知道什么时候
完成
(它可以在子
任务
完成
之前
发生
),我们不能在里面
等待
子
任务
。在这个片段中,我们将得到警告,因为外部
任务
在子
任务
之前
完成
: def create_sub_task()
浏览 3
提问于2016-06-08
得票数 1
回答已采纳
1
回答
如何防止
asyncio
.Task被取消
、
、
我正在实现优雅的关闭,需要
等待
某些
任务
才能在关闭应用程序之前
完成
执行。我正在
等待
在关闭处理程序中使用
asyncio
.gather(*
asyncio
.Task.all_tasks())的
任务
。但是,我遇到的问题是,创建并需要
等待
的
任务
在我杀死应用程序之后就会被取消,因此不会出现在
asyncio
.Task.get_all()中。如何防止这种情况
发生
?
浏览 6
提问于2022-07-14
得票数 0
回答已采纳
1
回答
asyncio
.ensure_future中的捕获错误
、
、
、
我有这样的代码:
asyncio
.ensure_future(data_streamer.sendByLatest()) logging.debug
浏览 2
提问于2016-05-03
得票数 10
回答已采纳
1
回答
当异步
任务
执行_blocking_工作
时
,如何在键盘中断上优雅地关闭?
、
更新:异步只需执行它被告知的操作,您就可以很好地处理这些
异常
--请参阅我标记为问题解决方案的后续答案。下面是最初的问题,并以稍加修改的例子来澄清这个问题及其解决方案。在编写一些示例代码
时
,我意识到有时执行键盘中断(CTRL)(很少!)引发了可怕的..。Task exception was never retrieved 我一直在努力确保我派生的所有
任务
都能优雅地处理
asyncio
.CancelledError,在花了太多时间调试它之后,我意识到只有当异步
任务
之一被阻塞操作卡住
时
(3600
浏览 5
提问于2021-12-17
得票数 2
回答已采纳
1
回答
Python异步:处理聚集()中的
异常
-文档不清楚?
、
说 这段代码所做的只是为了使它更简单,它定义了3个<e
浏览 0
提问于2019-03-04
得票数 29
回答已采纳
1
回答
在不丢失数据的情况下取消异步
、
tasks = [self.frontend_wrap(),completed, pending = await
asyncio
.wait(tasks, return_when=
asyncio
.FIRST_COMPLETED) i.cancel() do staff 换句话说,我在
等待
一个
任务
何时
完成
,并开始处理
浏览 5
提问于2018-01-22
得票数 0
1
回答
为什么BeautifulSoup与“从未检索到
任务
异常
”相关?
、
、
该程序可以在ubuntu 16.04的python3.5中运行良好,当所有的工作都
完成
后,它将退出。源代码如下。import aiohttpfrom bs4 import BeautifulSoup coro_loop =
asyncio
.get_event_looploop.run_forever() main() 在测试过程中,我发现当
浏览 14
提问于2017-08-06
得票数 1
回答已采纳
1
回答
如何使用run_in_executor对吗?
、
下面是代码(基本上是来自docs的复制)import concurrent.futures # CPU-bound operations: while True: await
asyncio
.sleep(1) loop =
浏览 0
提问于2019-05-22
得票数 3
1
回答
动态创建将永远运行的异步
任务
、
、
我需要动态创建异步
任务
(例如: loop.create_task()),这些
任务
将永远运行。更多背景: 谢谢你的帮助。
浏览 2
提问于2020-06-19
得票数 2
回答已采纳
1
回答
异步:投机性地
等待
多种期货
、
TL;DR 所以我需要这个。我想要创建一种特殊的未来/
任务
,它可以进行计时,如果它们累计超过某个超时(或在与此计时
任务
交互后被迫停止),则可以与其他未来/
任务
一起使用来取消它们。假设现在你被要求在每个项目点上
等待
完全超时--好吧,你已经超过你的配额超过两次了。因此,您需要将计算出的增量从每个调用传递到其后续调用。
浏览 4
提问于2017-10-17
得票数 5
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Python_学习之多协程
asyncio:Python异步编程模块
Python 异步 IO系列:认识asyncio
并发编程 协程加强篇2
在Python中实现异步编程,只需要这几步就够了
热门
标签
更多标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
活动推荐
运营活动
广告
关闭
领券