很多人做股票数据研究时都有过这样的经历从数据接口拉行情、写脚本算指标、再手工整理成日报每天至少消耗一个小时。更麻烦的是行情数据容易变动格式也不统一今天能跑的代码明天就报错。如果你曾在这个流程里浪费过时间那么daily_stock_analysis这类项目就值得认真看看。这个项目的核心并不复杂把每日股票分析流程沉淀成一个可重复执行的任务。它解决的不是“怎么预测涨跌”的问题而是“怎么让分析过程更高效、更规范、更可复用”的问题。读完这篇文章你会理解一个完整的股票数据分析流程包含哪些模块以及如何把数据获取、指标计算、信号筛选和报告输出串成一个自动化流程。需要先说明的是这类项目的主要价值在于帮助个人投资者和技术爱好者掌握数据采集、清洗、计算和展示的完整链路同时建立一个系统化的研究框架。本文会从项目结构、技术栈、核心代码、运行验证到工程化建议逐步展开。1. 项目到底解决了什么问题股票分析的原始工作流通常长这样打开行情软件手动记录一组股票代码然后去数据网站查收盘价、成交量再拿 Excel 计算均线、涨跌幅。如果只看三五只股票这种方式还能接受当股票池扩大到几十只甚至上百只时整个过程就会变得非常耗时而且极易出错。对于有一定编程基础的人来说更自然的做法是用 Python 写脚本自动完成。但很多人的脚本都有一个共性问题数据获取和业务逻辑耦合在同一个函数里今天换一个数据源就要重写一片代码指标计算逻辑写在临时脚本里没有统一封装输出结果要么打印在终端要么存成 CSV缺少可读性。daily_stock_analysis这类项目试图解决的正是上述问题。它将每日股票研究整理成标准流水线通常包含数据获取、数据清洗、指标计算、信号生成和结果输出几个固定步骤。只要运行一条命令就能得到当天的行情快照、技术指标和候选标的列表。这个项目的另一个价值在于它是一个很好的工程实践模板。很多初学者会写一次性的股票数据脚本但较少接触“把分析流程工程化”这件事——包括模块设计、配置管理、时间序列对齐、异常处理等。从学习的角度看研究一个完整项目比自己从零摸索要高效得多。当然也要有合理的预期。股票代码在分析时实际使用哪个数据接口很关键不同数据源在延迟、字段说明、频率限制上都有差异。本文的重点是帮助你建立一套可以自主扩展的分析框架而不是提供一个可以直接照抄的选股公式。2. 股票分析系统的整体架构在写代码之前先理解一个完整的每日股票分析系统通常分成哪几层。这能帮助你判断项目的模块边界也方便日后扩展。2.1 数据层数据层负责从外部获取行情数据和基本面数据。常见的公开数据源有 akshare、tushare、baostock、yfinance部分项目还会接入一些免费 API 或自行爬取网页数据。设计数据层时最需要关注的是接口兼容问题。不同数据源返回的字段名不一定相同有的叫close有的叫收盘有的返回的是 DataFrame有的返回的是 JSON。比较好的做法是统一封装一层适配器把外部数据转换为统一的 DataFrame 结构这样后续的指标计算模块就不需要关心数据来自哪里。2.2 计算层计算层负责生成技术指标包括移动平均线MA、指数移动平均线EMA、相对强弱指标RSI、随机指标KDJ、布林带BOLL等。实现方式有三种直接手写公式、使用 pandas 的 rolling/ewm 方法、调用 TA-Lib 等专业指标库。从学习价值看手写简单指标有助于理解原理比如MA 就是滚动窗口内的收盘价平均值。EMA 是带权重的均值近期数据权重更高。RSI 衡量一段时间内涨跌力量的相对强弱。从工程效率看如果股票池较大直接使用成熟的指标库更合适性能和正确性都有保障。计算层还需要注意时间序列对齐。A 股有停牌、涨跌停、节假日休市等情况不同股票的交易日可能不完全一致直接用shift和rolling时容易产生错位计算前通常要做sort_values和前向填充。2.3 信号层信号层根据规则生成交易信号。比如当短期均线如 MA5上穿长期均线如 MA20时产生“金叉”信号当 RSI 低于 30 时进入“超卖区”当收盘价突破布林带上轨时说明波动加大警惕回调风险。信号的意义在于把指标结果转化为可执行的研究结论。不同策略的差异主要体现在信号规则上所以在代码里信号规则应该是可配置的而不是硬编码在循环里。2.4 输出层输出层的任务是把结果展示给用户通常有以下几种形式终端打印适合快速验证输出 CSV / Excel适合后续在表格软件里分析生成 Markdown 日报或结合邮件、消息推送发送通知如果技术栈再大一些还可以把结果写入数据库配合前端图表展示。对于个人项目推荐先输出 CSV 或 Markdown 日报。成本低、可读性好还能直接共享给其他人看。3. 环境准备与前置条件在动手实践之前先检查一下本机环境。下面是推荐的基础环境如果你已经具备 Python 开发环境可以跳过部分步骤工具/库用途推荐版本Python主要开发语言3.9pandas数据处理2.xnumpy数值计算1.24akshare / tushare行情数据接口以实际安装版本为准matplotlib可视化可选3.xtabulate打印 Markdown 表格0.9版本说明不同数据接口库的版本更新较快接口字段也可能调整。本文重点演示通用思路具体版本请以实际项目为准不推荐死磕特定小版本。3.1 创建虚拟环境不论你使用 venv、virtualenv 还是 conda都强烈建议创建独立的虚拟环境避免不同项目之间的依赖冲突。mkdir daily_stock_analysis cd daily_stock_analysis python -m venv venv # Windows venv\Scripts\activate # macOS / Linux source venv/bin/activate创建虚拟环境后再安装依赖。这里只列最小依赖集实际项目可以按需添加pip install pandas numpy akshare tabulate如果项目需要输出图表可以追加安装 matplotlibpip install matplotlib3.2 项目目录结构一个结构合理的项目通常这样组织daily_stock_analysis/ ├── config.py # 配置项如股票池、指标参数 ├── data_fetcher.py # 数据获取模块 ├── indicators.py # 技术指标计算模块 ├── signals.py # 信号生成模块 ├── report.py # 输出与报告模块 ├── main.py # 调度入口 └── output/ # 输出目录拆分模块的目的只有一个让职责边界清晰方便测试和替换。如果你只是临时研究把全部代码写在一个文件里也能跑通但当股票池和策略变复杂后维护成本会迅速上升。4. 核心流程拆解下面把每日股票分析的核心流程拆成四步每一步都说明目标、输入、输出和常见坑点。4.1 获取行情数据第一步是拿到用于计算的原始数据。假设股票池配置如下# config.py STOCK_POOL [000001, 000858, 600519, 600036] START_DATE 20240101 END_DATE 20250101使用 akshare 获取日线行情的典型代码是# data_fetcher.py import akshare as ak def fetch_daily_data(stock_code: str, start_date: str, end_date: str): df ak.stock_zh_a_hist( symbolstock_code, perioddaily, start_datestart_date, end_dateend_date, adjustqfq ) return df这里adjustqfq表示前复权实际使用时要注意复权因子会随最新价格变化历史数据在不同日期取到的时间序列可能不同所以最好每天固定拉一次并保存快照不要反复回看同一区间。 这段代码返回的 DataFrame 里日期字段通常是字符串开盘价、最高价、最低价、收盘价、成交量等列默认是中文名。下一步需要统一列名。4.2 数据清洗与标准化不同数据源返回的字段名不一样所以标准化是必要步骤。统一改成英文小写列名方便后续代码引用# data_fetcher.py def normalize_columns(df): rename_map { 日期: date, 开盘: open, 收盘: close, 最高: high, 最低: low, 成交量: volume, 成交额: amount, 涨跌幅: pct_change, } df df.rename(columnsrename_map) df[date] pd.to_datetime(df[date]) df df[[date, open, close, high, low, volume, amount, pct_change]] return df标准化列名只是为了代码可读性没有技术上的强制要求但一个团队里如果每个人都用不一样的字段名写出来的指标计算代码很难复用。字段统一之后后续所有模块只需要面对同一种结构。清洗阶段还需要处理缺失值、去重和排序df df.drop_duplicates(subset[date]) df df.sort_values(date).reset_index(dropTrue)4.3 计算技术指标有了干净的数据就可以开始算指标。这里展示 MA、RSI 和 MACD 三个常见指标的计算方式。# indicators.py import pandas as pd def add_moving_average(df, window5): df[fma{window}] df[close].rolling(windowwindow).mean() return df def add_rsi(df, period14): delta df[close].diff() gain delta.clip(lower0) loss -delta.clip(upper0) avg_gain gain.rolling(windowperiod).mean() avg_loss loss.rolling(windowperiod).mean() rs avg_gain / avg_loss df[rsi] 100 - (100 / (1 rs)) return df需要注意RSI 在avg_loss为 0 时会出现除零问题。一种常见处理是把分母替换为极小值或者直接把 RSI 置为 100。在实际项目中用 pandas 的 ewm 方法计算平滑 RSI 会更接近主流行情软件的结果也可以直接用 TA-Lib。MA 的计算很直观rolling 表示滚动窗口默认值会取前 N 日的均值。窗口大小是策略的核心参数建议在配置里统一管理。4.4 生成信号与输出报告信号规则可以很简单也可以很复杂。这里演示一个相对容易理解的规则当 MA5 上穿 MA20且 RSI 不超过 70 时视为“关注信号”。# signals.py def generate_signal(df): df[signal] 持有观察 condition (df[ma5] df[ma20]) (df[ma5].shift(1) df[ma20].shift(1)) (df[rsi] 70) df.loc[condition, signal] 5日线上穿20日线关注 return df这个规则本身不是投资建议只是为了演示信号生成的代码结构。实践中不要把信号结果当成买卖依据它只是把规则固化成可重复计算的程序逻辑。最终输出部分推荐先输出 CSV后续再考虑 Markdown 或邮件。5. 完整示例代码实现综合上面的模块下面给出一个可以本地直接运行的完整示例。为了便于阅读理解示例只包含核心逻辑没有做复杂的错误处理。5.1 配置文件# config.py STOCK_POOL [000001, 000858, 600519, 600036] START_DATE 20240101 END_DATE 20250101 MA_SHORT 5 MA_LONG 20 RSI_PERIOD 14把参数放在配置里的好处是以后调整策略时不需要改代码只改配置。5.2 数据获取模块# data_fetcher.py import pandas as pd import akshare as ak def fetch_daily_data(stock_code: str, start_date: str, end_date: str) - pd.DataFrame: 获取单只股票的日线数据统一列名。 raw_df ak.stock_zh_a_hist( symbolstock_code, perioddaily, start_datestart_date, end_dateend_date, adjustqfq ) rename_map { 日期: date, 开盘: open, 收盘: close, 最高: high, 最低: low, 成交量: volume, 成交额: amount, 涨跌幅: pct_change, } df raw_df.rename(columnsrename_map) df[date] pd.to_datetime(df[date]) df df.drop_duplicates(subset[date]) df df.sort_values(date).reset_index(dropTrue) return df5.3 指标计算模块# indicators.py import pandas as pd def add_ma(df: pd.DataFrame, window: int) - pd.DataFrame: df[fma{window}] df[close].rolling(windowwindow).mean() return df def add_rsi(df: pd.DataFrame, period: int 14) - pd.DataFrame: delta df[close].diff() gain delta.clip(lower0) loss -delta.clip(upper0) avg_gain gain.ewm(alpha1 / period, min_periodsperiod).mean() avg_loss loss.ewm(alpha1 / period, min_periodsperiod).mean() rs avg_gain / avg_loss.replace(0, 1e-10) df[rsi] 100 - (100 / (1 rs)) return df这里使用 ewm 计算 RSI比简单 rolling 更平滑也更接近常见行情软件的结果。5.4 信号生成模块# signals.py import pandas as pd def add_signal(df: pd.DataFrame, short: int 5, long: int 20) - pd.DataFrame: df[signal] golden_cross (df[fma{short}] df[fma{long}]) (df[fma{short}].shift(1) df[fma{long}].shift(1)) df.loc[golden_cross, signal] fMA{short}上穿MA{long} return df5.5 主入口# main.py from config import STOCK_POOL, START_DATE, END_DATE, MA_SHORT, MA_LONG, RSI_PERIOD from data_fetcher import fetch_daily_data from indicators import add_ma, add_rsi from signals import add_signal def analyze_stock(stock_code: str): df fetch_daily_data(stock_code, START_DATE, END_DATE) df add_ma(df, MA_SHORT) df add_ma(df, MA_LONG) df add_rsi(df, RSI_PERIOD) df add_signal(df, MA_SHORT, MA_LONG) latest df.iloc[-1] print(f{stock_code} 最新交易日: {latest[date].date()}) print(f收盘价: {latest[close]}, MA{MA_SHORT}: {latest[fma{MA_SHORT}]:.2f}, MA{MA_LONG}: {latest[fma{MA_LONG}]:.2f}, RSI: {latest[rsi]:.2f}) print(f信号: {latest[signal]}) print(- * 40) return df if __name__ __main__: for code in STOCK_POOL: try: analyze_stock(code) except Exception as e: print(f{code} 分析失败: {e})运行这段代码控制台会逐只输出股票的最新行情、均线、RSI 和信号对于个人日常跟踪来说已经足够直观。6. 运行结果与效果验证在项目根目录执行python main.py正常情况下你会看到类似下面的输出000001 最新交易日: 2024-12-31 收盘价: 13.25, MA5: 13.10, MA20: 12.90, RSI: 55.32 信号: ---------------------------------------- 000858 最新交易日: 2024-12-31 收盘价: 145.80, MA5: 143.20, MA20: 141.50, RSI: 62.10 信号: MA5上穿MA20 ----------------------------------------注意真实数值取决于你配置的股票池和日期区间以上输出只是格式示例。如何判断运行成功核心标准是每只股票都有输出日期、价格、指标值都不是 NaN。如果某个股票的最新一行指标是 NaN通常是因为日期区间过短滚动窗口拿不到足够数据。这种情况下适当延长START_DATE到当前日期间隔即可。如果网络请求失败程序可能会抛异常。异常出现时第一件事不是改代码而是检查网络连接和数据源服务状态。很多免费数据源在交易时段和非交易时段返回的数据粒度不一样如果拉取的是日线数据尽量在收盘后运行脚本。7. 常见问题与排查思路在实际运行时最容易遇到的问题集中在数据获取、时间周期和指标计算三个环节。下面列出高频问题问题现象可能原因排查方式解决方案运行时提示找不到 akshare 模块未在当前虚拟环境安装依赖pip list检查依赖pip install akshare接口返回空数据股票代码格式不正确或区间无交易打开接口文档核对 symbol 格式A 股代码一般不带前缀港股美股要加后缀指标列出现 NaN滚动窗口期大于已有数据量打印 df 前几行查看延长日期范围或对 NaN 行做 dropna最新信号为空白当天不满足金叉条件打印最新几行 signal 列这是正常现象不代表代码错误数据源请求失败数据源临时限流或网络波动单独拉取一只股票测试延迟重试或切换备用数据源输出日期比预期少一天数据接口可能使用自然日而非交易日对比行情软件的交易日历使用交易日历过滤避免周末数据一个值得注意的坑是很多免费数据接口对请求频率有限制如果股票池很大且频繁启动脚本可能被临时限制访问。项目里建议加入“每次运行时限速”或“重复数据本地缓存”的逻辑。8. 最佳实践与工程建议当脚本能稳定跑通后下一步就是把它当成一个正式的小型工程去打磨。下面几条建议来自日常实践按重要程度排序。8.1 分离配置与代码股票池、日期区间、指标周期、复权方式等参数都应该放在配置文件中而不是散落在代码里。这样换一组股票或调整策略参数时不需要修改任何函数逻辑。更进一步可以使用configparser或yaml管理配置便于生成多种策略组合。8.2 数据保存与增量更新每次运行都全量拉取历史数据既慢又容易被限流。更合理的做法是把第一次拉取的数据保存到本地 CSV 或 SQLite之后每天只增量更新新交易日的数据。这样既减少了请求次数也保留了完整的本地数据集方便做回测。df.to_csv(fdata/{stock_code}.csv, indexFalse)增量更新的思路是读取本地已有数据只请求最新日期之后的数据然后合并去重。8.3 日志与异常报警个人脚本通常不太在意日志但当脚本要定时执行时日志就变得很重要。推荐使用 Python 自带的 logging 模块把每次运行的状态、异常信息都记录下来。如果配置了邮件或消息推送服务还可以在失败时发送提醒。import logging logging.basicConfig(filenamestock_analysis.log, levellogging.INFO)8.4 定时调度如果希望每天收盘后自动运行可以使用 cronLinux / macOS或任务计划程序Windows。比如每天 17:05 执行一次# crontab 示例周一至周五 17:05 运行 5 17 * * 1-5 cd /path/to/daily_stock_analysis /path/to/venv/bin/python main.py logs/run.log 21定时任务不是必须的但对于每天固定要做的事自动化能显著降低人工成本。8.5 关注数据合规与安全使用第三方数据接口时务必阅读数据提供方的使用条款不要高频抓取、不要商用没有授权的数据。涉及账号 token 或数据库连接串等敏感信息时不要硬编码在代码中推荐使用环境变量。自己写的脚本不要提交到公开仓库或者至少确保敏感信息被完全脱敏。8.6 指标正确性验证技术指标代码最容易出现的不是报错而是“算出来的结果和行情软件不一致”。原因包括复权方式不同、RSI 平滑算法不同、部分软件用shift方式导致金叉判断滞后一天等。验证的一个有效做法是选一只股票把指标序列和主流行情软件对比确认差异在可接受范围内再进行批量计算。不要盲目相信代码输出尤其当结果直接影响决策时。9. 总结与后续学习方向本文从一个每天手动重复的股票分析场景出发介绍了daily_stock_analysis类项目的模块划分、数据获取、指标计算、信号生成和报告输出流程。核心不是预测涨跌而是把分析过程标准化、自动化每次运行都能得到一致的结果避免手工操作带来的疏漏。如果你正在学习这个方向下一步可以按顺序做三件事先把你熟悉的几只股票纳入股票池跑通现有流程然后修改指标参数观察输出变化理解参数对信号的影响最后尝试加入一个新指标比如 MACD 或 KDJ加深对计算层的理解。这个项目继续深入的方向有很多把分析结果写入数据库配合定时任务形成每日数据仓库引入回测模块验证策略的历史表现接入图表可视化生成更直观的行情走势图甚至尝试用多因子方式筛选股票池进一步丰富分析维度。每一步都能独立展开而且都有成熟的 Python 库可以直接复用。对刚接触这个领域的读者最重要的一点是保持数据安全意识只使用合规的数据源不做高频请求不把隐私信息提交到公共仓库。技术能力可以慢慢积累但好的工程习惯应该从第一行代码就开始养成。建议把本文的基础框架保存下来先跑通再扩展你会发现自己很快就能拥有一套可用的每日股票分析工具。
用Python构建每日股票自动化分析流程：从数据获取到信号生成
很多人做股票数据研究时都有过这样的经历从数据接口拉行情、写脚本算指标、再手工整理成日报每天至少消耗一个小时。更麻烦的是行情数据容易变动格式也不统一今天能跑的代码明天就报错。如果你曾在这个流程里浪费过时间那么daily_stock_analysis这类项目就值得认真看看。这个项目的核心并不复杂把每日股票分析流程沉淀成一个可重复执行的任务。它解决的不是“怎么预测涨跌”的问题而是“怎么让分析过程更高效、更规范、更可复用”的问题。读完这篇文章你会理解一个完整的股票数据分析流程包含哪些模块以及如何把数据获取、指标计算、信号筛选和报告输出串成一个自动化流程。需要先说明的是这类项目的主要价值在于帮助个人投资者和技术爱好者掌握数据采集、清洗、计算和展示的完整链路同时建立一个系统化的研究框架。本文会从项目结构、技术栈、核心代码、运行验证到工程化建议逐步展开。1. 项目到底解决了什么问题股票分析的原始工作流通常长这样打开行情软件手动记录一组股票代码然后去数据网站查收盘价、成交量再拿 Excel 计算均线、涨跌幅。如果只看三五只股票这种方式还能接受当股票池扩大到几十只甚至上百只时整个过程就会变得非常耗时而且极易出错。对于有一定编程基础的人来说更自然的做法是用 Python 写脚本自动完成。但很多人的脚本都有一个共性问题数据获取和业务逻辑耦合在同一个函数里今天换一个数据源就要重写一片代码指标计算逻辑写在临时脚本里没有统一封装输出结果要么打印在终端要么存成 CSV缺少可读性。daily_stock_analysis这类项目试图解决的正是上述问题。它将每日股票研究整理成标准流水线通常包含数据获取、数据清洗、指标计算、信号生成和结果输出几个固定步骤。只要运行一条命令就能得到当天的行情快照、技术指标和候选标的列表。这个项目的另一个价值在于它是一个很好的工程实践模板。很多初学者会写一次性的股票数据脚本但较少接触“把分析流程工程化”这件事——包括模块设计、配置管理、时间序列对齐、异常处理等。从学习的角度看研究一个完整项目比自己从零摸索要高效得多。当然也要有合理的预期。股票代码在分析时实际使用哪个数据接口很关键不同数据源在延迟、字段说明、频率限制上都有差异。本文的重点是帮助你建立一套可以自主扩展的分析框架而不是提供一个可以直接照抄的选股公式。2. 股票分析系统的整体架构在写代码之前先理解一个完整的每日股票分析系统通常分成哪几层。这能帮助你判断项目的模块边界也方便日后扩展。2.1 数据层数据层负责从外部获取行情数据和基本面数据。常见的公开数据源有 akshare、tushare、baostock、yfinance部分项目还会接入一些免费 API 或自行爬取网页数据。设计数据层时最需要关注的是接口兼容问题。不同数据源返回的字段名不一定相同有的叫close有的叫收盘有的返回的是 DataFrame有的返回的是 JSON。比较好的做法是统一封装一层适配器把外部数据转换为统一的 DataFrame 结构这样后续的指标计算模块就不需要关心数据来自哪里。2.2 计算层计算层负责生成技术指标包括移动平均线MA、指数移动平均线EMA、相对强弱指标RSI、随机指标KDJ、布林带BOLL等。实现方式有三种直接手写公式、使用 pandas 的 rolling/ewm 方法、调用 TA-Lib 等专业指标库。从学习价值看手写简单指标有助于理解原理比如MA 就是滚动窗口内的收盘价平均值。EMA 是带权重的均值近期数据权重更高。RSI 衡量一段时间内涨跌力量的相对强弱。从工程效率看如果股票池较大直接使用成熟的指标库更合适性能和正确性都有保障。计算层还需要注意时间序列对齐。A 股有停牌、涨跌停、节假日休市等情况不同股票的交易日可能不完全一致直接用shift和rolling时容易产生错位计算前通常要做sort_values和前向填充。2.3 信号层信号层根据规则生成交易信号。比如当短期均线如 MA5上穿长期均线如 MA20时产生“金叉”信号当 RSI 低于 30 时进入“超卖区”当收盘价突破布林带上轨时说明波动加大警惕回调风险。信号的意义在于把指标结果转化为可执行的研究结论。不同策略的差异主要体现在信号规则上所以在代码里信号规则应该是可配置的而不是硬编码在循环里。2.4 输出层输出层的任务是把结果展示给用户通常有以下几种形式终端打印适合快速验证输出 CSV / Excel适合后续在表格软件里分析生成 Markdown 日报或结合邮件、消息推送发送通知如果技术栈再大一些还可以把结果写入数据库配合前端图表展示。对于个人项目推荐先输出 CSV 或 Markdown 日报。成本低、可读性好还能直接共享给其他人看。3. 环境准备与前置条件在动手实践之前先检查一下本机环境。下面是推荐的基础环境如果你已经具备 Python 开发环境可以跳过部分步骤工具/库用途推荐版本Python主要开发语言3.9pandas数据处理2.xnumpy数值计算1.24akshare / tushare行情数据接口以实际安装版本为准matplotlib可视化可选3.xtabulate打印 Markdown 表格0.9版本说明不同数据接口库的版本更新较快接口字段也可能调整。本文重点演示通用思路具体版本请以实际项目为准不推荐死磕特定小版本。3.1 创建虚拟环境不论你使用 venv、virtualenv 还是 conda都强烈建议创建独立的虚拟环境避免不同项目之间的依赖冲突。mkdir daily_stock_analysis cd daily_stock_analysis python -m venv venv # Windows venv\Scripts\activate # macOS / Linux source venv/bin/activate创建虚拟环境后再安装依赖。这里只列最小依赖集实际项目可以按需添加pip install pandas numpy akshare tabulate如果项目需要输出图表可以追加安装 matplotlibpip install matplotlib3.2 项目目录结构一个结构合理的项目通常这样组织daily_stock_analysis/ ├── config.py # 配置项如股票池、指标参数 ├── data_fetcher.py # 数据获取模块 ├── indicators.py # 技术指标计算模块 ├── signals.py # 信号生成模块 ├── report.py # 输出与报告模块 ├── main.py # 调度入口 └── output/ # 输出目录拆分模块的目的只有一个让职责边界清晰方便测试和替换。如果你只是临时研究把全部代码写在一个文件里也能跑通但当股票池和策略变复杂后维护成本会迅速上升。4. 核心流程拆解下面把每日股票分析的核心流程拆成四步每一步都说明目标、输入、输出和常见坑点。4.1 获取行情数据第一步是拿到用于计算的原始数据。假设股票池配置如下# config.py STOCK_POOL [000001, 000858, 600519, 600036] START_DATE 20240101 END_DATE 20250101使用 akshare 获取日线行情的典型代码是# data_fetcher.py import akshare as ak def fetch_daily_data(stock_code: str, start_date: str, end_date: str): df ak.stock_zh_a_hist( symbolstock_code, perioddaily, start_datestart_date, end_dateend_date, adjustqfq ) return df这里adjustqfq表示前复权实际使用时要注意复权因子会随最新价格变化历史数据在不同日期取到的时间序列可能不同所以最好每天固定拉一次并保存快照不要反复回看同一区间。 这段代码返回的 DataFrame 里日期字段通常是字符串开盘价、最高价、最低价、收盘价、成交量等列默认是中文名。下一步需要统一列名。4.2 数据清洗与标准化不同数据源返回的字段名不一样所以标准化是必要步骤。统一改成英文小写列名方便后续代码引用# data_fetcher.py def normalize_columns(df): rename_map { 日期: date, 开盘: open, 收盘: close, 最高: high, 最低: low, 成交量: volume, 成交额: amount, 涨跌幅: pct_change, } df df.rename(columnsrename_map) df[date] pd.to_datetime(df[date]) df df[[date, open, close, high, low, volume, amount, pct_change]] return df标准化列名只是为了代码可读性没有技术上的强制要求但一个团队里如果每个人都用不一样的字段名写出来的指标计算代码很难复用。字段统一之后后续所有模块只需要面对同一种结构。清洗阶段还需要处理缺失值、去重和排序df df.drop_duplicates(subset[date]) df df.sort_values(date).reset_index(dropTrue)4.3 计算技术指标有了干净的数据就可以开始算指标。这里展示 MA、RSI 和 MACD 三个常见指标的计算方式。# indicators.py import pandas as pd def add_moving_average(df, window5): df[fma{window}] df[close].rolling(windowwindow).mean() return df def add_rsi(df, period14): delta df[close].diff() gain delta.clip(lower0) loss -delta.clip(upper0) avg_gain gain.rolling(windowperiod).mean() avg_loss loss.rolling(windowperiod).mean() rs avg_gain / avg_loss df[rsi] 100 - (100 / (1 rs)) return df需要注意RSI 在avg_loss为 0 时会出现除零问题。一种常见处理是把分母替换为极小值或者直接把 RSI 置为 100。在实际项目中用 pandas 的 ewm 方法计算平滑 RSI 会更接近主流行情软件的结果也可以直接用 TA-Lib。MA 的计算很直观rolling 表示滚动窗口默认值会取前 N 日的均值。窗口大小是策略的核心参数建议在配置里统一管理。4.4 生成信号与输出报告信号规则可以很简单也可以很复杂。这里演示一个相对容易理解的规则当 MA5 上穿 MA20且 RSI 不超过 70 时视为“关注信号”。# signals.py def generate_signal(df): df[signal] 持有观察 condition (df[ma5] df[ma20]) (df[ma5].shift(1) df[ma20].shift(1)) (df[rsi] 70) df.loc[condition, signal] 5日线上穿20日线关注 return df这个规则本身不是投资建议只是为了演示信号生成的代码结构。实践中不要把信号结果当成买卖依据它只是把规则固化成可重复计算的程序逻辑。最终输出部分推荐先输出 CSV后续再考虑 Markdown 或邮件。5. 完整示例代码实现综合上面的模块下面给出一个可以本地直接运行的完整示例。为了便于阅读理解示例只包含核心逻辑没有做复杂的错误处理。5.1 配置文件# config.py STOCK_POOL [000001, 000858, 600519, 600036] START_DATE 20240101 END_DATE 20250101 MA_SHORT 5 MA_LONG 20 RSI_PERIOD 14把参数放在配置里的好处是以后调整策略时不需要改代码只改配置。5.2 数据获取模块# data_fetcher.py import pandas as pd import akshare as ak def fetch_daily_data(stock_code: str, start_date: str, end_date: str) - pd.DataFrame: 获取单只股票的日线数据统一列名。 raw_df ak.stock_zh_a_hist( symbolstock_code, perioddaily, start_datestart_date, end_dateend_date, adjustqfq ) rename_map { 日期: date, 开盘: open, 收盘: close, 最高: high, 最低: low, 成交量: volume, 成交额: amount, 涨跌幅: pct_change, } df raw_df.rename(columnsrename_map) df[date] pd.to_datetime(df[date]) df df.drop_duplicates(subset[date]) df df.sort_values(date).reset_index(dropTrue) return df5.3 指标计算模块# indicators.py import pandas as pd def add_ma(df: pd.DataFrame, window: int) - pd.DataFrame: df[fma{window}] df[close].rolling(windowwindow).mean() return df def add_rsi(df: pd.DataFrame, period: int 14) - pd.DataFrame: delta df[close].diff() gain delta.clip(lower0) loss -delta.clip(upper0) avg_gain gain.ewm(alpha1 / period, min_periodsperiod).mean() avg_loss loss.ewm(alpha1 / period, min_periodsperiod).mean() rs avg_gain / avg_loss.replace(0, 1e-10) df[rsi] 100 - (100 / (1 rs)) return df这里使用 ewm 计算 RSI比简单 rolling 更平滑也更接近常见行情软件的结果。5.4 信号生成模块# signals.py import pandas as pd def add_signal(df: pd.DataFrame, short: int 5, long: int 20) - pd.DataFrame: df[signal] golden_cross (df[fma{short}] df[fma{long}]) (df[fma{short}].shift(1) df[fma{long}].shift(1)) df.loc[golden_cross, signal] fMA{short}上穿MA{long} return df5.5 主入口# main.py from config import STOCK_POOL, START_DATE, END_DATE, MA_SHORT, MA_LONG, RSI_PERIOD from data_fetcher import fetch_daily_data from indicators import add_ma, add_rsi from signals import add_signal def analyze_stock(stock_code: str): df fetch_daily_data(stock_code, START_DATE, END_DATE) df add_ma(df, MA_SHORT) df add_ma(df, MA_LONG) df add_rsi(df, RSI_PERIOD) df add_signal(df, MA_SHORT, MA_LONG) latest df.iloc[-1] print(f{stock_code} 最新交易日: {latest[date].date()}) print(f收盘价: {latest[close]}, MA{MA_SHORT}: {latest[fma{MA_SHORT}]:.2f}, MA{MA_LONG}: {latest[fma{MA_LONG}]:.2f}, RSI: {latest[rsi]:.2f}) print(f信号: {latest[signal]}) print(- * 40) return df if __name__ __main__: for code in STOCK_POOL: try: analyze_stock(code) except Exception as e: print(f{code} 分析失败: {e})运行这段代码控制台会逐只输出股票的最新行情、均线、RSI 和信号对于个人日常跟踪来说已经足够直观。6. 运行结果与效果验证在项目根目录执行python main.py正常情况下你会看到类似下面的输出000001 最新交易日: 2024-12-31 收盘价: 13.25, MA5: 13.10, MA20: 12.90, RSI: 55.32 信号: ---------------------------------------- 000858 最新交易日: 2024-12-31 收盘价: 145.80, MA5: 143.20, MA20: 141.50, RSI: 62.10 信号: MA5上穿MA20 ----------------------------------------注意真实数值取决于你配置的股票池和日期区间以上输出只是格式示例。如何判断运行成功核心标准是每只股票都有输出日期、价格、指标值都不是 NaN。如果某个股票的最新一行指标是 NaN通常是因为日期区间过短滚动窗口拿不到足够数据。这种情况下适当延长START_DATE到当前日期间隔即可。如果网络请求失败程序可能会抛异常。异常出现时第一件事不是改代码而是检查网络连接和数据源服务状态。很多免费数据源在交易时段和非交易时段返回的数据粒度不一样如果拉取的是日线数据尽量在收盘后运行脚本。7. 常见问题与排查思路在实际运行时最容易遇到的问题集中在数据获取、时间周期和指标计算三个环节。下面列出高频问题问题现象可能原因排查方式解决方案运行时提示找不到 akshare 模块未在当前虚拟环境安装依赖pip list检查依赖pip install akshare接口返回空数据股票代码格式不正确或区间无交易打开接口文档核对 symbol 格式A 股代码一般不带前缀港股美股要加后缀指标列出现 NaN滚动窗口期大于已有数据量打印 df 前几行查看延长日期范围或对 NaN 行做 dropna最新信号为空白当天不满足金叉条件打印最新几行 signal 列这是正常现象不代表代码错误数据源请求失败数据源临时限流或网络波动单独拉取一只股票测试延迟重试或切换备用数据源输出日期比预期少一天数据接口可能使用自然日而非交易日对比行情软件的交易日历使用交易日历过滤避免周末数据一个值得注意的坑是很多免费数据接口对请求频率有限制如果股票池很大且频繁启动脚本可能被临时限制访问。项目里建议加入“每次运行时限速”或“重复数据本地缓存”的逻辑。8. 最佳实践与工程建议当脚本能稳定跑通后下一步就是把它当成一个正式的小型工程去打磨。下面几条建议来自日常实践按重要程度排序。8.1 分离配置与代码股票池、日期区间、指标周期、复权方式等参数都应该放在配置文件中而不是散落在代码里。这样换一组股票或调整策略参数时不需要修改任何函数逻辑。更进一步可以使用configparser或yaml管理配置便于生成多种策略组合。8.2 数据保存与增量更新每次运行都全量拉取历史数据既慢又容易被限流。更合理的做法是把第一次拉取的数据保存到本地 CSV 或 SQLite之后每天只增量更新新交易日的数据。这样既减少了请求次数也保留了完整的本地数据集方便做回测。df.to_csv(fdata/{stock_code}.csv, indexFalse)增量更新的思路是读取本地已有数据只请求最新日期之后的数据然后合并去重。8.3 日志与异常报警个人脚本通常不太在意日志但当脚本要定时执行时日志就变得很重要。推荐使用 Python 自带的 logging 模块把每次运行的状态、异常信息都记录下来。如果配置了邮件或消息推送服务还可以在失败时发送提醒。import logging logging.basicConfig(filenamestock_analysis.log, levellogging.INFO)8.4 定时调度如果希望每天收盘后自动运行可以使用 cronLinux / macOS或任务计划程序Windows。比如每天 17:05 执行一次# crontab 示例周一至周五 17:05 运行 5 17 * * 1-5 cd /path/to/daily_stock_analysis /path/to/venv/bin/python main.py logs/run.log 21定时任务不是必须的但对于每天固定要做的事自动化能显著降低人工成本。8.5 关注数据合规与安全使用第三方数据接口时务必阅读数据提供方的使用条款不要高频抓取、不要商用没有授权的数据。涉及账号 token 或数据库连接串等敏感信息时不要硬编码在代码中推荐使用环境变量。自己写的脚本不要提交到公开仓库或者至少确保敏感信息被完全脱敏。8.6 指标正确性验证技术指标代码最容易出现的不是报错而是“算出来的结果和行情软件不一致”。原因包括复权方式不同、RSI 平滑算法不同、部分软件用shift方式导致金叉判断滞后一天等。验证的一个有效做法是选一只股票把指标序列和主流行情软件对比确认差异在可接受范围内再进行批量计算。不要盲目相信代码输出尤其当结果直接影响决策时。9. 总结与后续学习方向本文从一个每天手动重复的股票分析场景出发介绍了daily_stock_analysis类项目的模块划分、数据获取、指标计算、信号生成和报告输出流程。核心不是预测涨跌而是把分析过程标准化、自动化每次运行都能得到一致的结果避免手工操作带来的疏漏。如果你正在学习这个方向下一步可以按顺序做三件事先把你熟悉的几只股票纳入股票池跑通现有流程然后修改指标参数观察输出变化理解参数对信号的影响最后尝试加入一个新指标比如 MACD 或 KDJ加深对计算层的理解。这个项目继续深入的方向有很多把分析结果写入数据库配合定时任务形成每日数据仓库引入回测模块验证策略的历史表现接入图表可视化生成更直观的行情走势图甚至尝试用多因子方式筛选股票池进一步丰富分析维度。每一步都能独立展开而且都有成熟的 Python 库可以直接复用。对刚接触这个领域的读者最重要的一点是保持数据安全意识只使用合规的数据源不做高频请求不把隐私信息提交到公共仓库。技术能力可以慢慢积累但好的工程习惯应该从第一行代码就开始养成。建议把本文的基础框架保存下来先跑通再扩展你会发现自己很快就能拥有一套可用的每日股票分析工具。
