🟡 待办：moneyflow（个股资金流向）导入模块缺失，表为空（曾与cashflow混淆） #23

New Issue

2026-08-15T16:45:50+08:00

xiaowu commented

2026-08-15 16:45:50 +08:00

🟡 待办：moneyflow（个股资金流向）导入模块缺失，表为空

现象

数据库 moneyflow 表 0 行（2026-08-15 检查确认）
8/13 曾评论"增加了moneyflow导入模块，已导入部分数据"——疑似与 cashflow（现金流量表）混淆，cashflow 数据正常（257,551 行），moneyflow 实为空
Gitea 仓库中无任何 moneyflow 导入代码（importer.py 无函数、增量脚本未含、ipynb 无 cell、git 历史无提交）

现状确认

表	行数	说明
moneyflow	0	❌ 空表，无导入模块
cashflow	257,551	✅ 正常（现金流量表，别混淆）

需要做的事（爸爸抽空处理）

在 quantitative_data/importer.py 增加 moneyflow 导入函数
- Tushare 接口 moneyflow 已实测可用（code 0，5120 积分够），按 trade_date 全市场拉取
- 字段：buy_sm_vol/buy_sm_amount/sell_sm_vol/.../net_mf_vol/net_mf_amount（schema 已建好，见 schema.sql）
- 唯一约束：(ts_code, trade_date)，UPSERT 幂等
把 moneyflow 纳入 incremental_import.py 增量循环（目前 TABLE_SPECS 无 moneyflow）
推送 Gitea 后，手动跑一次补历史数据（建议从 2026-01-01 或更早开始）

参考

接口实测：/opt/quant-venv/bin/python tushare_api_check.py（moneyflow 项 ✅）
表结构：quantitative_data/schema.sql 中 moneyflow DDL

## 🟡 待办：moneyflow（个股资金流向）导入模块缺失，表为空 ### 现象 - 数据库 `moneyflow` 表 **0 行**（2026-08-15 检查确认） - 8/13 曾评论"增加了moneyflow导入模块，已导入部分数据"——**疑似与 cashflow（现金流量表）混淆**，cashflow 数据正常（257,551 行），moneyflow 实为空 - Gitea 仓库中无任何 moneyflow 导入代码（importer.py 无函数、增量脚本未含、ipynb 无 cell、git 历史无提交） ### 现状确认 | 表 | 行数 | 说明 | |---|---|---| | moneyflow | 0 | ❌ 空表，无导入模块 | | cashflow | 257,551 | ✅ 正常（现金流量表，别混淆） | ### 需要做的事（爸爸抽空处理） 1. 在 `quantitative_data/importer.py` 增加 `moneyflow` 导入函数 - Tushare 接口 `moneyflow` 已实测可用（code 0，5120 积分够），按 `trade_date` 全市场拉取 - 字段：buy_sm_vol/buy_sm_amount/sell_sm_vol/.../net_mf_vol/net_mf_amount（schema 已建好，见 schema.sql） - 唯一约束：`(ts_code, trade_date)`，UPSERT 幂等 2. 把 moneyflow 纳入 `incremental_import.py` 增量循环（目前 TABLE_SPECS 无 moneyflow） 3. 推送 Gitea 后，手动跑一次补历史数据（建议从 2026-01-01 或更早开始） ### 参考 - 接口实测：`/opt/quant-venv/bin/python tushare_api_check.py`（moneyflow 项 ✅） - 表结构：`quantitative_data/schema.sql` 中 moneyflow DDL

shellway commented

2026-08-16 09:20:32 +08:00

@xiaowu 已经往importer.py里面增加了moneyflow导入的模块，确认是否添加成功。

xiaowu commented

2026-08-17 11:33:24 +08:00

已确认：moneyflow 导入模块添加成功 ✅

quantitative_data/importer.py（master 分支，1662 行）：

import_moneyflow()（L773）：按 trade_date 或 ts_code 导入，内部 batch_insert("moneyflow", ...)
import_moneyflow_by_date()（L861）：按交易日批量全市场导入，配合 fetch_with_retry
fetch_moneyflow()（L915）：单交易日拉取 + 重试

quantitative_data/incremental_import.py：

L52 表映射已含 "moneyflow": ("trade_date", ["ts_code", "trade_date"])
L109 增量任务清单已含 moneyflow，L134-135 走 import_moneyflow_by_date

下一步建议：跑一次增量导入（如 python incremental_import.py 或指定日期范围）验证表里有数据，需要的话我可以继续跟进。

（另：说明一下，之前没回复是因为我目前不会主动轮询 Gitea，@ 我收不到提醒；这问题我正在想办法解决。）

已确认：moneyflow 导入模块添加成功 ✅ `quantitative_data/importer.py`（master 分支，1662 行）： - `import_moneyflow()`（L773）：按 trade_date 或 ts_code 导入，内部 `batch_insert("moneyflow", ...)` - `import_moneyflow_by_date()`（L861）：按交易日批量全市场导入，配合 `fetch_with_retry` - `fetch_moneyflow()`（L915）：单交易日拉取 + 重试 `quantitative_data/incremental_import.py`： - L52 表映射已含 `"moneyflow": ("trade_date", ["ts_code", "trade_date"])` - L109 增量任务清单已含 moneyflow，L134-135 走 `import_moneyflow_by_date` 下一步建议：跑一次增量导入（如 `python incremental_import.py` 或指定日期范围）验证表里有数据，需要的话我可以继续跟进。（另：说明一下，之前没回复是因为我目前不会主动轮询 Gitea，@ 我收不到提醒；这问题我正在想办法解决。）

Sign in to join this conversation.

2 Participants

Notifications

Due Date

No due date set.

Dependencies

No dependencies set.

Reference: shellway/quanxiel#23

🦸‍♂️亲爱的，永远不要忘记，你为什么来到这里。

🟡 待办：moneyflow（个股资金流向）导入模块缺失，表为空（曾与cashflow混淆） #23