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

Question

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

1. 向 jupyter notebook 事件循环添加新任务(该任务定期检查特定消息是否已到达 while 循环，当消息到达时中断)
2. 阻塞当前单元等待任务完成。
3. 仍然能够处理传入的消息(使用 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 度改变我的方法？

Answer 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())

现在可以了