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

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

内容简介:翻译自: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


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

查看所有标签

猜你喜欢:

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

创新

创新

理查德·福斯特 / 王宇锋 / 中信出版社 / 2008-10 / 32.00元

《创新:进攻者的优势》内容简介:为什么一流企业突然间将它们的市场拱手让与新的竞争者?要避免这样的命运,需要无情地抛弃那些过去使它们成功的技能和产品,那么究竟哪些企业能够做到这一点呢?企业如果总是墨守成规、因循守旧,那么长期下去,必然无法以市场的速度及规模进行革新或创造价值。这样的企业会像得州仪器、施乐等市场领先者一样,被一些资源较少、技术较差、市场支配力较弱的竞争对手超越,而这些所谓进攻者的优势,......一起来看看 《创新》 这本书的介绍吧!

RGB转16进制工具
RGB转16进制工具

RGB HEX 互转工具

MD5 加密
MD5 加密

MD5 加密工具

RGB CMYK 转换工具
RGB CMYK 转换工具

RGB CMYK 互转工具