问：KDB+/PyQ 发布者订阅者使用 python 对象中的提要

Question

我一直在尝试重现发布者订阅者示例： https://code.kx.com/wiki/Cookbook/publishsubscribe

就纯粹与 q 相关的情况而言，一切正常。

我一直在尝试使用 PyQ 内核在 jupyter notebook 中重现订阅者。 我没有成功地在 python 对象中获取订阅者输出/提要。每次，订阅者都会在内核输出（控制台）中打印。

我也一直在尝试在 PyQ 中复制类似于我在 java 客户端上看到的用于 q 的内容，但没有取得多大成功(https://code.kx.com/q/interfaces/java-client-for-q/)

我最理想的目标是：

• 在命令行中运行我的发布者（到目前为止，这是非常简单的部分）
• 拥有一个 Python 笔记本，用于侦听我的发布者发布的端口并在新提要进入时处理事件
• websocket 解决方案将非常出色

是否有人对如何在 python 端执行此操作有一些指示？有什么例子吗？

非常感谢， 耶尔·达蒙

Answer 1

为了将 q 输出重定向到 Jupyter 笔记本，您应该为 %%q 单元魔术指定 -1（对于标准输出）和 -2（对于标准错误）选项。

我希望它在 python 对象中

您可以通过将标准流重定向到管道来捕获它们。例如，在 Linux 上你可以这样做

>>> import os
>>> r,w = os.pipe()
>>> q('\\2 /dev/fd/%d' % w)
k('::')
>>> q('-2 "hello"')
k('-2')
>>> os.read(r, 5)
b'hello'

请注意，我使用 stderr 进行说明，因为重定向 stdout 会干扰 REPL 显示，但同样的技术适用于 stdout。使用管道的常见警告适用。管道的缓冲区有限，因此您需要安排定期读取。通常，这将涉及某种超出此答案范围的事件管理。如果您不想处理这种复杂性，最好的办法是使用临时文件而不是管道。我还建议研究如何在 pytest 中实现“fdcap”fixture。