1 在开盘时间中，python从第三方提供的api获取tick和bar数据（例如都是df或ndarray格式）

2 一旦获得数据立即同步到dolphindb两张流表中

3 流数据表实时计算特征 (1、特征计算过程写在dolphindb GUI内还是用python api中直接 session.run(脚本)呢？ 2、其中tick表最后应输出TICK级别特征和聚合输出bar级别的特征)

4 计算完后（这里看交易频率，可以按TICK也可以按1MIN，另外就是计算完的特征单独存在特征表好呢还是就相应写入tick/bar行情表？），dolphindb通知Python, python去相应的表中取得特征

5 新行情进入，循环1-5

我想先写一个demo，特征可以是很简单的先把流程走通跑起来，

请问我要用到哪些知识点 (可以用伪代码大概写一下给我吗) ，划一些重点给我，我针对性的去搜教程，多谢！

默认排序时间排序

1 个回答

Alex - dba 2021-12-11 12:18

第3点请参阅k线计算教程https://gitee.com/dolphindb/Tutorials_CN/blob/master/OHLC.md

计算过程写在GUI内，调试完成后可写入startup.dos，详见：启动脚本教程https://gitee.com/dolphindb/Tutorials_CN/blob/master/Startup.md 和节点启动时的流计算自动订阅教程

https://gitee.com/dolphindb/Tutorials_CN/blob/master/streaming_auto_sub.md

4. 在python api中启动订阅，请参阅 python api 教程第10节 Python Streaming API部分

相似问题