我正在使用此处找到的tick.q文件https://github.com/KxSystems/kdb-tick/blob/master/tick.q
我正在使用下面的脚本将一堆 csv 加载到 q 实例中。尽管打开了我的 tp 端口,但数据并未正确发送给它。当您加载批量 csv 数据而不是实时流数据时,我对如何通过 tp 发送数据有点困惑。
所以我基本上已经在 feed 实例上以表格格式正确加载了所有数据,但对于下一步该做什么有点困惑。有人可以提供有关如何配置的指导吗?
饲料.q
h:hopen`::5010
fPath:{.Q.dd [`:/Users/dt/hb/rpcoreData/histData/csvs]x}'[key `:/Users/dt/hb/rpcoreData/histData/csvs]
fPath1:{.Q.dd[x] each key x}'[fPath]
rpr:raze {("**************************";enlist",") 0: read0 each x}'[raze fPath1]
i:0
feed:{if[count[rpr]>=i;(neg h)(`.u.upd;`rpr;value rpr i);i+:1]}
.z.ts:feed
\t 100
\l /Users/dt/hb/ht/parse_scripts/parserp.q
您正在异步发布数据,并且不会刷新输出队列。我相信这可能与此有关。但是,您应该将数据从 feed 同步发送到 TP。您可以在此处查看简单 feedhandler 的实现 https://code.kx.com/q/wp/rt-tick/#feedhandler-fh 并且您可以在此处阅读有关 tick.q 如何工作的更多信息 https:/ /www.defconq.tech/docs/tutorials/tick 希望这有帮助