claude_dev e97f845424 fix(data): partition_reader 类型兼容规则真数据精化——NAS 真数据冒烟实锤 EM 源对全空列写 arrow null 型,同域 part 文件间 null↔double 漂移合法,原 fail-loud 按字面执行拒掉全部合法数据;修=全空列通配(与任意类型兼容)+数值族 int↔float 互通(金额元值<2^53 无精度损 concat 升位)+全空 object 列规整 float64;真冲突收窄为 text↔num 与列集增删;TDD 换血:fail 用例改 text↔num+新增 null↔double 兼容/int↔float 升位两例,416 绿 [vps] [no-doc]

2026-09-17 23:52:21 +08:00

..

__init__.py

feat(data): 脚手架 + YAML 配置加载

2026-07-05 11:41:57 +08:00

config.py

feat(deploy): VPS原生大脑部署—env覆盖配置+部署文档(Option B落地)

2026-07-15 12:55:58 +08:00

corpus_reader.py

feat(data): corpus/dmsk 消费接口(spec §20.11.3 实施,设计已入档)——partition_reader 通用读取核(核内零语义:不做 as-of/PIT+零静默去重;失败分级:缺数据空 df 不 raise/跨分区列集与类型漂移 PartitionSchemaError fail loud;双机根解析 SANGUO_CORPUS_ROOT/SANGUO_FUND_DMSK_ROOT env 覆盖+水位线读取)+corpus_reader(get_news_meta/get_ann_meta symbols 下推 stock_code/sec_code/get_news_fulltext(ids) art_code 批量/ann_pdf_dir;schema 契约 09-17 NAS 实测落 docstring:稳定 id=art_code/announcement_id 与 PDF 同名)+fund_dmsk_reader(get_domain 五域+noticed_by 纯过滤 NOTICE_DATE 缺列 fail loud;契约:五域 NOTICE_DATE 实测全在/SECUCODE 带后缀 SECURITY_CODE 裸 6 位/单位元);TDD 23 例,全套 414 绿 [vps] [no-doc]

2026-09-17 23:44:02 +08:00

datafeed.py

feat(data): DataFeed 多源 fallback + BaoStock 超时修复

2026-07-05 12:41:00 +08:00

datareader.py

perf(data): 四热路径日期区间SARGable化——substr(datetime,1,10)对索引列套函数打不进复合索引datetime列,每股扫全量日线史取短窗——08-25晨9:30生产实锤:momentum选股1/2(RPS池)174s未达<60s验收,阶段日志精确定罪(过滤段含双seek仅7.8s);病根=PanelFetcher的30天窗SQL每只股扫~5000行日线史取~22行,3226只≈1600万行=174s量级吻合。修=裸列datetime>=start AND datetime<end+1天排他上界(与按日期前10位比较在d裸日期/15m·5m时间戳两格式下语义严格等价,含end当日全部行排除次日),区间打进复合索引第4列每股只扫窗口行。四处同病同修:PanelFetcher宽表/PriceFetcher逐只get_price/limit-status近2根90天窗(原substr版90天下界同样打不进索引)/datareader CTA回测K线。+3测试:防回潮扫描(三文件钉死禁substr谓词)+双格式边界行为(d裸日期与15m时间戳end当日含次日排)+get_price同语义;portfolio+data_platform 644绿;待VPS探针终验计时 [vps]

2026-08-25 20:54:40 +08:00

datawriter.py

feat(data): DataWriter 原子写 parquet + vnpy SQLite

2026-07-05 12:43:18 +08:00

dividend_source.py

feat(trader): C期分期项收尾—资金占用成本+分红送股+_restore_ledger修复

2026-07-10 08:44:35 +08:00

fund_dmsk_reader.py

feat(data): corpus/dmsk 消费接口(spec §20.11.3 实施,设计已入档)——partition_reader 通用读取核(核内零语义:不做 as-of/PIT+零静默去重;失败分级:缺数据空 df 不 raise/跨分区列集与类型漂移 PartitionSchemaError fail loud;双机根解析 SANGUO_CORPUS_ROOT/SANGUO_FUND_DMSK_ROOT env 覆盖+水位线读取)+corpus_reader(get_news_meta/get_ann_meta symbols 下推 stock_code/sec_code/get_news_fulltext(ids) art_code 批量/ann_pdf_dir;schema 契约 09-17 NAS 实测落 docstring:稳定 id=art_code/announcement_id 与 PDF 同名)+fund_dmsk_reader(get_domain 五域+noticed_by 纯过滤 NOTICE_DATE 缺列 fail loud;契约:五域 NOTICE_DATE 实测全在/SECUCODE 带后缀 SECURITY_CODE 裸 6 位/单位元);TDD 23 例,全套 414 绿 [vps] [no-doc]

2026-09-17 23:44:02 +08:00

index_downloader.py

fix(data): baostock参数 adjustfield→adjustflag(真实参数名)

2026-07-11 15:00:05 +08:00

partition_reader.py

fix(data): partition_reader 类型兼容规则真数据精化——NAS 真数据冒烟实锤 EM 源对全空列写 arrow null 型,同域 part 文件间 null↔double 漂移合法,原 fail-loud 按字面执行拒掉全部合法数据;修=全空列通配(与任意类型兼容)+数值族 int↔float 互通(金额元值<2^53 无精度损 concat 升位)+全空 object 列规整 float64;真冲突收窄为 text↔num 与列集增删;TDD 换血:fail 用例改 text↔num+新增 null↔double 兼容/int↔float 升位两例,416 绿 [vps] [no-doc]

2026-09-17 23:52:21 +08:00

scheduler.py

feat(data): UpdateScheduler 增量 + 断点续传 + 熔断

2026-07-05 16:14:23 +08:00

validator.py

feat(data): 移植 v1 validator + 适配接口 + 测试

2026-07-05 11:53:51 +08:00