关于tdengine:一只股票一张表-TDengine-在青岛金融研究院量化分析场景中的应用
小 T 导读:对于青岛协同翻新金融研究院来说,始终打交道的交易记录、价格等数据均为时序数据,在抉择数据库(Database)时,TDengine “一个设施一张表”的设计吸引了他们的眼光。目前 TDengine 曾经在其生产零碎中稳固运行了 38 周。本文总结了他们在选型、搭建等方面的所思所想,以及利用 TDengine 之后所获得的成果。 企业简介:为切实服务国家经济、金融倒退,中国金融量化迷信与技术协同翻新核心在山东青岛设立了一个高端智库,即青岛协同翻新金融研究院。依靠于翻新核心的国内顶级专家资源、在量化金融与金融科技领域的国内当先实践钻研与实务技术成绩,研究院致力于促成我国金融畛域创新型尖端实践人才、适用性高端技术人才的教育与造就,晋升相干畛域在风险管理、资产定价、产品设计等各方面的定量分析与决策技术水平,踊跃保护金融稳固、促成金融倒退。 单刀直入地说,咱们抉择 TDengine 的理由很简略——“一个设施一张表”的模型很适宜咱们的量化剖析场景。实质上来讲,交易记录、价格等都是时序数据,其实就是“一只股票一张表”,所以非常符合。 在咱们的业务场景中,TDengine 次要负责三点:一是对回测的数据反对,因为它能够轻松抗住海量数据的写入。目前咱们的数据入库形式是应用 Python 连接器间接写入 TDengine(6030 端口)。具体形式为:会通过券商的直连贯口将他们提供的数据做一个 SQL 拼接,利用拼接 SQL 的形式,单个 SQL 写入几千行数据,将少量数据一次性写入到一个表中。目前,咱们每天新增数据量大略在 2000 万行左右。 (注:股票回测是指设定了某些股票指标组合后,基于历史曾经产生过的实在行情数据,在历史上某一个工夫点开始,严格依照设定的组合进行选股,并模仿实在金融市场交易的规定进行模型买入、模型卖出,得出一个时间段内的盈利率、最大回撤率等数据。) 二是基于以上数据进行的回测数据分析。 三是局部盘中策略的数据预加载。 但因为这块有每秒几万次的查问用在高频业务上,所以临时还没有尝试利用 TDengine,目前大部分盘中业务应用的还是 Redis。据社区工作人员示意,将来的 TDengine 3.0 版本将会反对自定义工夫范畴的缓存,届时或者能够帮到咱们。 除了上述次要的应用场景之外,TDengine 还帮忙咱们实现了局部深度学习模型的数据训练和测试。 具体落地与实际效果在目前的业务中,咱们选用了三台 8 核 16G 服务器,以此搭建了三正本的集群。 这里大家须要留神,三节点并不代表三正本,也并不代表你的数据库曾经具备了高可用性。数据库的高可用是在 "create database xxxx replica 1/2/3" 的过程中指定的,然而如果你遗记了也没关系,前期能够通过 "alter database xxxx replica 1/2/3" 来动静地进行调整。TDengine 会主动复制出一批分片(Vnode),并平均地散布在各个节点之上,成果如下”show 库名.vgroups”所示。 (注:如果数据量很大,在数据同步的过程中因为网络稳定导致数据文件复制中断,也能够手动复制 Vnode 目录下的文件到指定节点再启动。) 依据不同类型的业务,咱们创立了 7 张不同的超级表,子表数量为 33076 张,目前咱们导入的数据总量曾经达到了 46 亿之多,其中最大的一张超级表白到了 26 亿行,理论磁盘占用大略在 130GB 左右。表的列数如下图”columns”所示,数据类型以 Float 为主。 ...