如何使用KDB实现动态订户？

debugcn 发表于 Dev

公理

我正在尝试在kdb-tick系统中实现动态订户，从而根据使用者提供的查询将事件的子集传递给给定的使用者。

例如给定一批事件，即：

flip `source`channel`value!(10?`a`b`c;10?`a`b`c;10?10)

source channel value
--------------------
a      a       4
b      b       5
a      c       4
b      a       2
c      c       7
c      b       8
c      a       5
a      c       6
b      a       4
b      a       1

报价装置只应发送没有`c通道的事件，即

source channel value
--------------------
a      a       4
b      b       5 
b      a       2 
c      b       8
c      a       5 
b      a       4
b      a       1

我试图通过解析动态条件来实现此目的，如下所示：

q).tp.subscribers

hp        | host isOpen port   h   subs
----------| --------------------------------------------------
:test:5000| test 0      5000   6   "enlist(not;(in;`channel;enlist`c))"

其中，subs是功能选择语句的条件参数，该条件选择语句在以下代码中使用：

.tp.send:{neg[x] y};

.tp.reval:{[batch;subscriber]
  .tp.send[raze .subscriber`h] reval[parse["?[batch;",raze[subscriber`subs],";0b;()]"]]
  };

// Called with event batch 
.tp.broadcast:{[batch]
   .tp.reval[batch]'[select from .tp.subscribers where isOpen] 
  };

由于无法通过功能选择语句在非全局上下文中无法处理批处理，因此此操作失败。我想知道如何有效地实现此功能？

任何人都可以向我提出建议或向我指出与该问题陈述的解决方案有关的信息。您的建议将不胜感激。抱歉，如果这是一个新手问题。谢谢

特里林奇

我认为您期望条件参数的字符串形式是您的问题的一部分（这反过来要求您进行parse字符串化的功能选择，并且解析假定为全局）。

为什么不期望有条件参数的列表形式呢？然后，无需解析，您可以创建本地功能选择。例如

.tp.subscribers:([hp:1#`:test:5000]subs:enlist(not;(in;`channel;1#`c)))

q){[batch] reval ?[batch;(0!.tp.subscribers)`subs;0b;()]}flip `source`channel`value!(10?`a`b`c;10?`a`b`c;10?10)
source channel value
--------------------
a      a       4
b      b       5
b      a       2
c      b       8
c      a       5
b      a       4
b      a       1

或者让用户指定一个lambda并运行它（尽管我想您会失去reval在这种情况下使用的能力）：

.tp.subscribers:([hp:1#`:test:5000]subs:enlist{select from x where not channel=`c})

q){[batch] @[first(0!.tp.subscribers)`subs;batch;()]}flip `source`channel`value!(10?`a`b`c;10?`a`b`c;10?10)
source channel value
--------------------
a      b       9
c      b       0
b      b       0
b      a       9
b      a       3
b      a       9

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。