kdb中的表更新回调

时间 2019-02-19
阅读 110
点赞 0
收藏 0
连接hades

我想在kdb客户机可以自己注册以在更新某些表时接收回调。

我知道在kdb中回调是如何工作的,我无法计算如何将服务器中的表更新绑定到我可以调用的函数上。callback“从客户那里。

建议答案

基本上,您希望实现“发布订阅”机制。kdb在tick库中已经有一个脚本“u.q”,它提供了:https://code.kx.com/q/cookbook/publish-subscribe/

在服务器上,它维护客户机列表及其句柄、订阅表和回调函数。您必须更改服务器上处理数据插入/更新的功能,以便发布数据。

q)  .u.pub[table name; table data]

这将负责调用为该表注册的每个客户端的回调函数。

在客户端,创建到发布服务器的连接并调用库函数进行订阅。

q) .u.sub[tablename;list_of_symbols_to_subscribe_to]

您还可以查看示例发布者和订户代码:https://github.com/KxSystems/cookbook/tree/master/pubsub

👍 0