内容简介：翻译自：https://stackoverflow.com/questions/46667697/block-jupyter-notebook-cell-execution-till-specific-message-received
实现异步的分布式计算引擎,它与jupyter notebook兼容.该系统应该基于“推送通知”方法,这使得(几乎,我希望)不可能允许用户等待特定的计算结果(即,给定笔记本单元的块执行直到具有预期结果的消息被传递).确切地说,我试图：
>将新任务添加到jupyter notebook事件循环(任务定期检查特定msg是否已在循环中到达,当msg到达时中断)
>阻止当前单元格等待任务完成.
>仍然能够处理传入的消息(使用RabbitMQ,Pika,从 http://pika.readthedocs.io/en/0.10.0/examples/asynchronous_consumer_example.html 略微修改的代码)
我准备了笔记本来展示我的问题： https://github.com/SLEEP-MAN/RabbitMQ_jupyterNotebook_asyncio
有任何想法吗？是否有可能(可能是一些IPython / IpyKernel魔法;>？),或者我必须将我的方法改变180度？
您的问题是您将两个不同的循环混合在一起.这就是为什么它不起作用.你需要做一些改变.
使用AsyncioConnection而不是TornadoConnection
return adapters.AsyncioConnection(pika.URLParameters(self._url),
self.on_connection_open)
接下来你需要删除下面的行
self._connection.ioloop.start() #throws exception but not a problem...
因为你的循环已经在连接中启动了.然后你需要使用下面的代码等待
loop = asyncio.get_event_loop() loop.run_until_complete(wait_for_eval())
现在它有效
翻译自：https://stackoverflow.com/questions/46667697/block-jupyter-notebook-cell-execution-till-specific-message-received
以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，也希望大家多多支持 码农网
猜你喜欢:
- 阻止某个 NuGet 包意外升级
- 阻止恶意SSL通信六要点
- ios – 阻止递归和打破保留周期
- 如何阻止别人非法链接你网站的图片？
- vue拦截(阻止）浏览器后退事件
- 突破前端反调试：阻止页面不断 debugger
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
颠覆式创新：移动互联网时代的生存法则
李善友 / 机械工业出版社 / 2015-3-1
为什么把每件事情都做对了，仍有可能错失城池？为什么无人可敌的领先企业，却在一夜之间虎落平阳？短短三年间诺基亚陨落，摩托罗拉以区区29亿美元出售给联想，芯片业霸主英特尔在移动芯片领域份额几乎为零，风光无限的巨头转眼成为被颠覆的恐龙，默默无闻的小公司一战成名迅速崛起，令人瞠目结舌的现象几乎都能被“颠覆式创新”法则所解释。 颠覆式创新教你在新的商业竞争中“换操作系统”而不是“打补丁”，小公司用破坏......一起来看看 《颠覆式创新：移动互联网时代的生存法则》 这本书的介绍吧!
UNIX 时间戳转换
UNIX 时间戳转换
HEX HSV 转换工具
HEX HSV 互换工具