股票数据本地化存储实战:JSON、数据库与列式存储的方案对比
2026/8/10 19:40:55 网站建设 项目流程

股票数据本地化存储实战:JSON、数据库与列式存储的方案对比

如果你打算把股票数据存到本地,第一件事就是选型。我在这条路上踩过不少坑,从最初的纯JSON文件存储,到后来的SQLite数据库,再到现在用的列式数据库,每一步都有故事。这篇文章我把三种方案在股票数据场景下的优劣做一个详细对比,包括写入性能、查询性能、维护成本、适用场景等维度,并用实际数据做基准测试,帮你少走弯路。

先明确股票数据的特点

在讨论存储方案之前,得先理解股票数据的独特性。它和普通的业务数据不一样,有几个鲜明的特征:

一是数据量随时间线性增长。每只股票每个交易日产生一条日K线,A股5000多只股票,每年250个交易日,一年就是125万条记录。如果加上分钟级别数据,量会更大。

二是写入模式以追加为主。K线数据基本只会增加,很少修改。实时行情虽然是覆盖式更新,但历史数据是追加写入。

三是查询模式以聚合和扫描为主。分析时很少按单条记录查,更多的是按时间范围、按行业、按指标做聚合运算(求均值、求和、分组统计),这时候列式存储的优势就体现出来了。

四是时间序列特征明显。股票数据天然带有时间维度,按日期分表或按日期分区是常见的做法。

理解了这些特点,再来看三种存储方案的对比。

方案一:JSON文件存储

这是我最早用的方案。每只股票一个JSON文件,存放在按日期组织的目录里。比如data/daily/20260810/600519.json,文件内容是当天的行情数据。

{"dm":"600519","mc":"贵州茅台","cjsj":"20260810","open":1680.00,"high":1720.50,"low":1675.00,"cjjg":1715.80,"cjl":3500000,"amount":6005000000}

JSON方案的优点是简单直观,不需要任何数据库依赖,读写用标准库的json模块就行。文件备份和迁移也很方便,直接拷贝目录。我的第一版原型用的就是这个方案,半天就搞定了。

但很快就遇到了问题。第一个问题是查询。比如我想查贵州茅台2024年全年的收盘价,需要遍历250个JSON文件,每个文件都要打开、解析、提取字段,跑一次要好几秒。如果要按行业统计所有白酒股的平均成交量,那简直是灾难——要打开几千个文件,做几千次JSON解析。

第二个问题是数据一致性。JSON文件没有事务支持,如果在写入过程中程序崩溃,可能产生半写的文件。我遇到过这种情况:某次批量更新跑到一半重启了,导致部分股票当天的数据缺失,排查起来很麻烦。

第三个问题是空间效率。JSON的文本格式非常冗余,比如字段名"cjjg"在每个文件里都要存一遍。我测了一下,同样的数据量,JSON占用的空间是二进制格式的3到5倍。

方案二:SQLite数据库

从JSON切换到SQLite是一个自然的选择。SQLite是单文件数据库,支持标准SQL,零部署,非常适合个人项目和小团队。

CREATETABLEkline(dmTEXTNOTNULL,cjsjTEXTNOTNULL,cjjgREAL,cjlREAL,PRIMARYKEY(dm,cjsj));CREATEINDEXidx_kline_cjsjONkline(cjsj);

SQLite的优势非常明显。首先是查询能力,用SQL做聚合、排序、分组都很方便。比如查贵州茅台2024年全年收盘价,一行SQL就搞定:

SELECTcjsj,cjjgFROMklineWHEREdm='600519'ANDcjsjBETWEEN'20240101'AND'20241231'ORDERBYcjsj;

其次是事务支持,批量写入时用BEGIN/COMMIT包裹,要么全部写入要么全部回滚,数据一致性有保障。

第三是空间效率,内部用二进制存储,比JSON小很多。我测了同样5000只股票一年日K线的数据:JSON约45MB,SQLite约12MB,压缩比接近4:1。

但SQLite也有局限。最主要的是并发能力,写入操作是串行的,多个进程同时写入会锁库。对于我们这种场景(每天定时批量写入)问题不大,但如果需要高频实时写入行情数据,就会遇到瓶颈。

另一个问题是分析性能。当数据量达到百万级后,复杂的聚合查询会变慢。比如要计算全市场所有股票过去一年的平均换手率,SQLite需要扫描全表,耗时可能在秒级。

方案三:列式存储(DuckDB)

为了解决分析性能的问题,我开始调研列式存储。列式数据库的核心思想是数据按列存储而不是按行存储,这样在做聚合查询时只读需要的列,IO效率大幅提升。我选择了DuckDB,它和SQLite一样是嵌入式数据库,零部署,但内部是列式架构。

importduckdb conn=duckdb.connect("stock.duckdb")conn.execute(""" CREATE TABLE kline ( dm VARCHAR, cjsj VARCHAR, cjjg DOUBLE, cjl DOUBLE ) """)conn.execute("CREATE INDEX idx_cjsj ON kline(cjsj)")

DuckDB的查询性能确实惊人。同样的全市场聚合查询,SQLite要3秒,DuckDB只需要0.2秒。而且DuckDB支持向量化计算,在做因子计算(比如对每只股票求过去20天的移动平均)时,速度比SQLite快一个数量级。

DuckDB的另一个优点是和Python生态的集成非常好,直接支持pandas DataFrame的读写,做数据分析时可以无缝衔接。

不过DuckDB也有不足。一是写入性能,由于是列式存储,单行写入效率较低,适合批量写入。二是生态相对年轻,文档和社区资源不如SQLite丰富。三是对于高频小更新的场景(比如实时行情逐笔写入),列式存储不是最优选择。

基准测试:三种方案的真实较量

说了这么多,不如直接上数据。我用全市场5000只股票、2023-2025共3年的日K线数据做了基准测试。数据总量约375万条记录(5000股 × 250天/年 × 3年)。

测试环境是Windows 11,Python 3.11,SQLite 3.43,DuckDB 1.1。JSON用的是标准json模块。

测试一:写入性能

测试方法:将375万条K线数据写入空库,记录总耗时。

JSON方案采用每个股票一个文件,并行写入(8线程),耗时约180秒。

SQLite采用批量INSERT,用BEGIN/COMMIT包裹,耗时约45秒。

DuckDB采用批量INSERT,耗时约30秒。

方案写入耗时单条平均
JSON(并行)180秒480μs
SQLite45秒120μs
DuckDB30秒80μs

测试二:单股时间范围查询

测试方法:查询贵州茅台3年的日K线(约750条记录)。

JSON:遍历750个文件,逐个解析提取字段,耗时约3.2秒。

SQLite:带索引的范围查询,耗时约15ms。

DuckDB:同样的查询,耗时约5ms。

方案查询耗时
JSON3200ms
SQLite15ms
DuckDB5ms

测试三:全市场聚合查询

测试方法:计算每个行业的平均收盘价、平均成交量。

JSON:需要遍历所有文件、解析、提取、分组、聚合,耗时超过60秒(实际上我没等完)。

SQLite:用SQL的GROUP BY,耗时约2.8秒。

DuckDB:同样的SQL,耗时约0.15秒。

SELECThy,AVG(cjjg),AVG(cjl)FROMklineJOINstock_infoONkline.dm=stock_info.dmWHEREcjsjBETWEEN'20230101'AND'20251231'GROUPBYhy;
方案聚合查询耗时
JSON>60秒
SQLite2.8秒
DuckDB0.15秒

测试四:存储空间

同样375万条数据:

JSON文件:约168MB
SQLite:约42MB
DuckDB:约38MB
(如果用Parquet格式存储,压缩后约12MB)

选型建议

综合以上测试结果,给出我的选型建议:

如果你是纯新手,或者只是做一些简单的单股票分析,JSON方案可以先用起来,快速验证想法。但要注意控制数据量,建议按日期分目录,避免单个目录文件过多。

如果你是个人开发者或小团队,需要做全市场的数据分析,SQLite是最佳选择。它的性能在大部分场景下够用,而且零运维成本。我的建议是按年分库,比如stock_2023.db、stock_2024.db,避免单库过大。

如果你有更高的分析需求,比如需要频繁做跨周期、跨行业的聚合运算,或者需要做因子回测,DuckDB是更好的选择。它的列式架构在分析型查询中优势明显,而且和Python生态的集成非常顺畅。

我的实际做法是混合使用:历史K线用DuckDB存储,方便做复杂分析;实时行情用SQLite,方便快速查询;基础信息(股票列表、行业分类)用JSON文件,方便配置管理。这样各取所长,覆盖不同的使用场景。

最后说一点,存储方案不是一成不变的。我自己的路径是:JSON → SQLite → DuckDB,每一步都是因为需求推动的。不用一开始就追求最优解,先用起来,当现有方案遇到瓶颈时再升级。对于股票数据存储来说,够用比完美更重要。

接口说明

接口路径用途核心参数核心返回字段
base/gplist获取全市场股票列表-dm, mc, hy, ssrq
time/real/{dm}获取实时行情dm=股票代码f43(现价), f47(成交量), f58(时间), f169(方向)
time/history/trade/{dm}/{level}获取历史K线dm=代码, level=周期klines(时间,开,收,高,低,量)
time/f10/fi/{dm}获取财务指标dm=股票代码营收, 净利润, ROE等
time/real/trace/l2sign/{dm}获取L2指标dm=股票代码ddx, ddy, ddz, ddf
time/real/trace/onebyone/{dm}获取逐笔交易dm=股票代码cjsj, cjjg, cjl, jyzd
time/zijin/zlzjzs/{dm}获取资金走势dm=股票代码zlJlr, zlJlb, shJlb
time/zijin/zjlrqs/{dm}获取资金趋势dm=股票代码f5MinZlJe等
time/data/longhubang获取龙虎榜数据日期营业部, 买入金额, 卖出金额
time/data/bshgt获取北向资金数据日期沪股通, 深股通净流入

资料参考:ig50.com

需要专业的网站建设服务?

联系我们获取免费的网站建设咨询和方案报价,让我们帮助您实现业务目标

立即咨询