时间戳

首页 > 解决方案 > jupyter notebook 之间的自定义消息

python - jupyter notebook 之间的自定义消息

问题描述

是否可以以某种方式使用 Anaconda 的 ZMQ 部分在 jupyter 笔记本之间进行自定义消息传递？我的意图是，如果有一个有限的解决方案，我为什么要编写自己的通信解决方案，或者安装新的东西:-) 我想查询所有可用的笔记本，如果需要的笔记本启动并运行，那么我想发送自定义，将数据流式传输到该笔记本。（以前我使用纯 .py 脚本使用 asyncio 套接字服务器/客户端架构来实现）。

不幸的是，消息传递文档对我没有太大帮助。

先感谢您！

sm。

标签： pythonjupyter-notebookzeromqmessaging

解决方案

问：“是否可以以某种方式使用 Anaconda 的 ZMQ 部分在 jupyter 笔记本之间进行自定义消息传递？”

当然。

选项 A：
可以扩展 jupyter 框架以在 FOSS 核心中包含所有新功能

选项 B：
可以在 jupyter 内部信令/消息传递功能之上并独立于 jupyter 内部信令/消息传递功能实例化自己的 ZeroMQ 信令/消息传递基础设施，并且只使用纯用户级代码。

include zmq

my1stContextINSTANCE = zmq.context()                          # The Engine
my1stPublisherSOCKET = my1stContextINSTANCE.socket( zmq.PUB ) #        its Socket
my1stPublisherSOCKET.setsockopt( zmq.LINGER,       0 )        #            configurations
my1stPublisherSOCKET.setsockopt( zmq.SNDBUF, 2000000 )        #            ...
...
my1stPullDataSOCKET  = my1stContextINSTANCE.socket( zmq.PULL )#        its Socket
my1stPullDataSOCKET.setsockopt( zmq.LINGER,        0 )        #            configurations
my1stPullDataSOCKET.setsockopt( zmq.RCVBUF,   100000 )        #            ...

...

while True:
   ...
   my1stPublisherSOCKET.send( "INF: message payload[{0:}]".format( repr( _ ) ) )
   ...
   if ( my1stPullDataSOCKET.poll( 0 ) ) ... ):
       ...

   elseif:
       ...

   else:
       ...

   continue

在所有其他对等方上相互相同。

无论哪种方式，ZeroMQ 框架都很聪明。您可能想阅读此和此。

架构设计和实施智慧和稳健性是你的。

推荐阅读