阻止 jupyter notebook 单元执行，直到收到特定消息

Posted 2023-03-30

【中文标题】阻止 jupyter notebook 单元执行，直到收到特定消息

【英文标题】：Block jupyter notebook cell execution till specific message received

【发布时间】：2017-10-10 13:13:22

【问题描述】：

我正在尝试为 python 实现异步分布式计算引擎，它与 jupyter notebook 兼容。该系统应该基于“推送通知”方法，这使得（几乎，我希望）不可能允许用户等待特定的计算结果（即阻止给定笔记本单元的执行，直到传递具有预期结果的消息）。准确地说，我正在尝试：

向 jupyter notebook 事件循环添加新任务（该任务定期检查特定 msg 是否已到达 while 循环，当 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 度？

【问题讨论】：

添加了测试答案，请查看

【参考方案1】：

您的问题是您将两个不同的循环混合在一起。这就是为什么它不起作用。您需要进行一些更改。

使用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())

现在它可以工作了