模块索引

August 29, 2026 · View on GitHub

源码根目录：src/cnequity/。包按数据层与职责划分，遵循「adapter 薄、step 编排、domain 契约」原则。

cnequity/
├── __init__.py
├── __main__.py          → cli()
├── file_lock.py         跨平台文件锁（POSIX flock / Windows msvcrt）
├── config/              配置加载
├── domain/              Schema、数据集注册、符号、限速
├── adapters/            外部数据源 I/O
├── orchestrator/        引擎、manifest、worker pool
├── steps/               注册采集步骤（按数据层分文件）
├── storage/             Parquet 湖读写、布局、水位
├── derive/              派生计算
├── quality/             审计与 failover
├── query/               消费层 API
├── serve/               只读湖面板（cne serve）
└── cli/                 Click 命令

依赖方向

cli → orchestrator → steps → adapters
                    ↓
              storage / derive / quality
                    ↓
                  query（只读 curated/derived）

query 不依赖 orchestrator 执行路径，仅读湖内文件与 Config 路径。

serve 只读，且只读已落盘的产物（注册表、目录布局、meta/stats、meta/quality、manifest）——不扫 curated，不写湖。

模块文档

模块	文档	核心文件
config	config.md	`loader.py`
domain	domain.md	`schemas.py`, `datasets.py`, `symbols.py`
adapters	adapters/README.md	各源子包
orchestrator	orchestrator.md	`engine.py`, `manifest.py`
steps	steps.md	`reference.py` … `finalize.py`
storage	storage.md	`parquet.py`, `layout.py`, `state.py`
derive	derive.md	`adj_factors.py`, `trading_status_history.py`
quality	quality.md	`audit.py`, `failover.py`
query	query.md	`reader.py`, `views.py`
serve	serve.md	`app.py`, `lake.py`
cli	cli.md	`main.py`

扩展点

要做什么	改哪里
新数据集	`domain/schemas.py` + `datasets.py` + `steps/<layer>.py` + adapter
新数据源	`adapters/<source>/` + `configs` sources 段
新 CLI 命令	`cli/<group>_cmds.py`（按用途选文件，见 cli 模块）
新质量检查	`quality/dataset_checks.py` 或 `cross_checks.py`
调度变更	`configs/cnequity.toml` waves/groups

导入副作用

import cnequity.steps（CLI 与 engine 启动时）会执行各 step 模块的 @register_step，填充 STEP_REGISTRY。新增 step 必须在 steps/__init__.py 中 import。

依赖方向

模块文档

扩展点

导入副作用

相关文档