CNEquity

CNEquity 开源、免注册、自托管。它不负责给出交易信号，而是把分散在不同来源、不同口径、不同更新节奏的数据，长期保存在自己的机器或服务器上，并且说明每一行从哪里来、何时采到、截至哪一天可用。

为什么要一个数据湖

发出一次 API 请求通常不是最费事的部分。真正困难的是长期保持研究口径一致：

• 多源一致性：字段、代码体系、更新节奏和可回补范围并不相同；
• 历史可复现：每次研究都现场拉取，结果会随上游变化而漂移；
• Universe 完整性：用今天的股票名单回看过去，会自动删掉后来退市的股票；
• PIT 语义：财报、公告和估值必须按当时实际可获得的日期查询；
• 复权与交易状态：如果每个研究脚本各自处理，口径很快就会分叉。

幸存者偏差是一个直观例子。下面的实验使用同一个等权买入持有策略和同一段时间，唯一差别是历史股票池里是否保留后来退市的股票。只用今天仍在交易的股票时，2016–2021 年的收益从 5.9% 变成了 12.0%：

那些股票不是收益为零，而是根本没有进入计算。CNEquity 因此把退市股、复权因子、历史成分和 PIT（按当时可获得的信息取数）放在数据层里处理，而不是交给每个下游脚本临时拼接。

数据范围

项目当前的主线是中国市场的 A 股研究，不追求把所有金融数据都收进来。已注册数据集覆盖：

• 证券主数据、交易日历和交易状态；
• 个股、指数、行业和板块的日线、分钟线、分笔与复权因子；
• 公司行为、公告索引和业绩披露预约；
• 财报、估值、股本、股东和分析师一致预期；
• 北向、融资融券、龙虎榜、大宗交易和资金流；
• 指数成分、行业分类、宏观指标和市场宽度；
• 新闻、快讯、情绪、轮动，以及解禁和监管事件。

当前注册表包含 42 个数据集：39 个 curated + 3 个 derived，按研究用途分为 L0–L8 九类。

所有 curated 行都带有 source、data_version 和 fetched_at，可以追到来源和采集批次。分钟线、5 分钟线和分笔默认关闭，按需启用；部分只能获取当日快照的数据集不会被伪造成历史序列。

完整字段、主键、历史模式和源端限制见数据集目录。 events:* 是 7×24 事件流组：公告和资讯周末也发，由 cne run events 按自然日跑， 不受交易日门禁限制（见配置 · 事件流调度组）。

○ 表示可选数据集，空表不算异常。逐项说明见数据集目录，源端限制见数据源说明。

适合什么场景

CNEquity 适合需要反复使用同一份历史数据的研究和数据工作：

• 多年行情回测，不想每次重新拉取、清洗和拼接复权；
• 需要把退市股、历史成分股和 PIT 纳入研究；
• 希望数据保存在本地或自己的服务器上，格式开放且来源可追溯；
• 想让 Python、DuckDB、Polars 和 AI agent 读取同一份数据。

如果只是查一只股票的最新价格，直接调用数据接口通常更轻。这个项目更适合需要持续积累、反复查询和复查结果的场景。

30 秒试玩

需要 Python 3.10+，无需 token、积分或账号：

pip install cnequity
cne demo

cne demo 默认拉取 5 只股票最近约 30 个交易日的真实数据，写入独立目录 data/cnequity-demo/，不会覆盖正式数据湖。需要能访问 TDX 行情主机；如果连接失败，可以先检查：

cne sources probe --only tdx_protocol

完全无法连接 TDX 时，运行 cne demo --sample，可离线验证安装、Parquet 落盘和查询链路。合成行全部标记为 source=mock，不可用于研究。

然后在 Python 中读取：

from cnequity.query import load

bars = load("daily_bars", data_root="data/cnequity-demo")
print(bars.tail())

想直接比较原始价格与后复权口径：

cne demo --research --symbols 600519.SH

5 分钟开始建湖

pip install cnequity
cne config init            # 生成 configs/cnequity.toml
cne init                   # 全市场标的，默认回溯最近 3 年
cne run daily              # 之后每个交易日执行这一条

默认策略是“浅而不窄”：历史先取最近 3 年，但全市场标的一个不缺。这样不会因为只保留今天仍上市的股票，提前把幸存者偏差写进数据湖。每个数据集的真实起点会记录在 coverage_start。

需要更长历史时可以一次拉满，也可以以后补深：

cne init --profile full

# 或对单个数据集补历史
cne backfill daily_bars --start 2016-01-01 --end <coverage_start>

默认初始化通常是小时级、GB 级，实际取决于网络、数据源状态和机器配置。详细安装说明见快速开始和安装指南。

能回答哪些问题

常用查询：

from cnequity.query import load

bars = load(
    "daily_bars",
    start="2020-01-01",
    end="2025-12-31",
    symbols=["600519.SH"],
    adjust="hfq",
)

roe = load(
    "financial_statement_items",
    items=["roe"],
    as_of="2024-04-30",
)

架构

架构上的边界比较简单：适配器负责把多源数据取回来；编排层负责 DAG、批次和重试；数据先进入 staging，再压实为 curated 并计算 derived；质量层持续审计；查询和服务层只读消费。展开见架构说明。

日常使用与运维

cne run daily                 # 执行当天全部日更分组
cne status                    # 查看 FRESH / STALE / EMPTY
cne serve                     # 打开 http://127.0.0.1:8787
cne sources probe                   # 检查上游数据源健康度
cne retry --run-id <run_id>   # 只重试失败批次
cne retry --failed-groups     # 重试各 daily 分组最新的失败 run

单个 step 失败时，系统会记录 failed batch，其他步骤继续落盘；重试不会把整条任务重新跑一遍。浏览器控制台可以查看覆盖、新鲜度、容量、跑批和质量结果。

挂入 crontab 即可自动日更：

# 交易日收盘后执行；非交易日会自动跳过
30 16 * * 1-5  cd /path/to/lake && cne run daily >> logs/daily.log 2>&1

更多运维方式见运行手册、数据源健康检查和故障排查。

接给 AI agent

cne mcp 以只读方式把本地湖提供给模型；采集、重试和清理仍由 CLI 完成。

cne mcp --config "$(pwd)/configs/cnequity.toml"

把上面的命令作为 MCP server 注册到任意兼容客户端即可。大多数客户端使用等价的配置（客户端名称和界面可能不同）：

{
  "mcpServers": {
    "cnequity": {
      "command": "cne",
      "args": ["mcp", "--config", "/abs/path/to/cnequity.toml"]
    }
  }
}

--config 必须使用绝对路径。接好后可以直接问：

• “茅台过去五年复权后涨了多少？”
• “茅台当前 PE 在自己五年历史里处于什么分位？”
• “计算 2018 年财报因子的 IC，不要使用未来数据。”
• “过去三年退市的股票，退市前 60 天有什么共同形态？”

还没有正式湖时，可以先运行 cne demo，再使用生成的 demo 配置。完整说明见MCP 参考。

与 AkShare、Tushare、Qlib 有什么不同

A