python – 阻止jupyter笔记本单元格执行,直到收到特定消息

栏目: Python · 发布时间: 5年前

内容简介:翻译自:https://stackoverflow.com/questions/46667697/block-jupyter-notebook-cell-execution-till-specific-message-received
我正在尝试为 python

实现异步的分布式计算引擎,它与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())

现在它有效

python – 阻止jupyter笔记本单元格执行,直到收到特定消息

翻译自:https://stackoverflow.com/questions/46667697/block-jupyter-notebook-cell-execution-till-specific-message-received


以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

产品型社群

产品型社群

李善友 / 机械工业出版社 / 2015-3-1 / CNY 69.00

传统模式企业正在直面一场空前的“降维战争”, 结局惨烈,或生或死。 传统模式很难避免悲惨下场, 诺基亚等昔日庞然大物轰然倒塌, 柯达发明了数码成像技术却依然破产, 新商业的兴起到底遵循的是什么模式? 微信轻而易举干掉了运营商的短信业务, “好未来”为何让传统教育不明觉厉? 花间堂为什么不是酒店,而是入口? 将来不会有互联网企业与传统企业之分, ......一起来看看 《产品型社群》 这本书的介绍吧!

SHA 加密
SHA 加密

SHA 加密工具

XML、JSON 在线转换
XML、JSON 在线转换

在线XML、JSON转换工具

HEX HSV 转换工具
HEX HSV 转换工具

HEX HSV 互换工具