从手动决策到Agent辅助:本地数据如何重构我的交易决策流程
从手动决策到WorkBuddy辅助:本地数据如何重构我的交易决策流程
写在前面
做交易的人,都经历过"拍脑袋决策"的时刻。
看到股票涨停了,追不追?看到主力资金流入了,买不买?看到龙虎榜上榜了,跟不跟?这些决策往往要在几秒内做出,但人脑在高压状态下的判断很容易出错——要么追高被套,要么踏空后悔。
后来我用WorkBuddy结合本地股票数据ig50落盘方案,构建了一套辅助决策体系。WorkBuddy可以在几秒内分析多个维度,给出一个综合评分,帮助我做出更理性的决策。
注意,我说的是"辅助决策",不是"自动交易"。WorkBuddy的评分是参考,最终的买卖决策还是靠自己。但有了WorkBuddy的辅助,决策的质量和效率都提升了一个量级。
今天想分享的,就是WorkBuddy如何帮我重构交易决策流程。
第一阶段:手动决策的痛点
典型的决策场景
做短线交易,典型的决策场景是这样的:
场景一:看到股票涨停 - 脑子里的想法:追不追?会不会炸板?主力资金有没有流入? - 时间压力:涨停后几秒内就要决定,犹豫就买不进去了 场景二:看到主力资金大幅流入 - 脑子里的想法:买不买?是真实流入还是对倒?北向资金有没有在买? - 时间压力:资金流入后股价可能快速拉升,犹豫就追高了 场景三:看到龙虎榜上榜 - 脑子里的想法:跟不跟?机构买的还是游资买的?买入金额多大? - 时间压力:龙虎榜数据盘后才披露,第二天开盘要快速决定这些决策场景,共同的问题是:要在几秒内综合多个维度的信息,做出判断。但人脑在高压状态下,很难全面考虑所有因素,容易做出冲动决策。
冲动决策的后果
冲动决策的后果,往往是:
- 追高被套:看到涨停就追,结果炸板被套
- 踏空后悔:犹豫不敢买,结果一路涨停错过
- 盲目跟风:看到龙虎榜就买,结果游资第二天就砸盘
后来我意识到,需要一套辅助决策系统,帮我在几秒内综合分析多个维度,给出一个客观的评分。
第二阶段:WorkBuddy如何辅助决策
WorkBuddy可以在几秒内分析多个维度
用WorkBuddy结合本地数据,可以在几秒内完成多维分析。而且因为是本地文件读取,速度取决于你的CPU、内存和硬盘速度;如果用多线程把多个数据源一次性预加载到内存,后续的单股分析可以降到毫秒级。
fromconcurrent.futuresimportThreadPoolExecutordefload_analysis_data():"""WorkBuddy多线程预加载所有决策所需数据"""data_files={'main_fund':DATA_DIR/'stock-a'/'主力资金流向','north_money':DATA_DIR/'stock-center'/'北向资金','longhubang':DATA_DIR/'stock-a'/'龙虎榜','limit_up':DATA_DIR/'stock-a'/'涨停股池'}defload_file(item):name,path=itemwithopen(path,'r',encoding='utf-8')asf:data=json.load(f)returnname,{d['股票代码']:dfordindata}# WorkBuddy多线程并行预加载4个数据源withThreadPoolExecutor(max_workers=4)asexecutor:results=list(executor.map(load_file,data_files.items()))returndict(results)# WorkBuddy启动时预加载数据(秒级完成)data_cache=load_analysis_data()defquick_analysis(code):"""WorkBuddy快速分析单只股票(基于内存中的缓存数据)"""score=0reasons=[]# 从内存缓存中读取数据,毫秒级main_dict=data_cache['main_fund']north_dict=data_cache['north_money']lb_dict=data_cache['longhubang']limit_dict=data_cache['limit_up']# 维度一:主力资金流向ifcodeinmain_dict:main_inflow=float(main_dict[code].get('主力净流入(万元)',0))ifmain_inflow>1000:score+=30reasons.append(f"主力资金流入{main_inflow:.0f}万元")# 维度二:北向资金ifcodeinnorth_dict:north_buy=float(north_dict[code].get('增持股数(万股)',0))ifnorth_buy>10:score+=25reasons.append(f"北向资金增持{north_buy:.0f}万股")# 维度三:龙虎榜ifcodeinlb_dict:org_buy=float(lb_dict[code].get('机构净买入(万元)',0))iforg_buy>500:score+=20reasons.append(f"机构买入{org_buy:.0f}万元")# 维度四:涨停股池ifcodeinlimit_dict:score+=15reasons.append("进入涨停股池")# 维度五:涨停强度limit_up_times=int(limit_dict[code].get('涨停次数',0))iflimit_up_times>=2:score+=10reasons.append(f"连板{limit_up_times}天")return{'code':code,'score':score,'reasons':reasons}# WorkBuddy快速分析(基于内存缓存,毫秒级)result=quick_analysis('000001')print(f"股票:{result['code']}")print(f"评分:{result['score']}分")print(f"理由:{', '.join(result['reasons'])}")WorkBuddy可以在几秒内完成5个维度的分析,给出一个综合评分:
股票:000001 评分:65分 理由:主力资金流入1500万元, 北向资金增持20万股, 进入涨停股池WorkBuddy的评分是参考,不是圣杯
需要强调的是,WorkBuddy的评分只是参考,不能直接作为买卖信号。
评分高的股票,不一定就涨;评分低的股票,也不一定就跌。WorkBuddy做的是信息整合和快速分析,帮助我在几秒内看到多个维度的情况,做出更理性的决策。
我的做法是:
- 评分>60分:重点关注,结合盘面判断是否买入
- 评分30-60分:观察,不急于操作
- 评分<30分:谨慎,风险较大
第三阶段:决策流程重构
从拍脑袋到系统化决策
有了WorkBuddy辅助之后,我的决策流程从"拍脑袋"变成了"系统化":
之前:拍脑袋决策
看到涨停 → 犹豫 → 追高/踏空 看到资金流入 → 犹豫 → 追高/踏空 看到龙虎榜 → 犹豫 → 跟风/错过现在:系统化决策
看到异动 → WorkBuddy快速分析(3秒) → 看评分和理由 → 结合盘面判断 → 做决策决策时间从"几秒犹豫"变成了"几秒拿到分析结果",决策质量明显提升。
WorkBuddy辅助决策的核心价值
WorkBuddy辅助决策的核心价值是:
- 信息整合:把分散在不同数据源的信息整合起来
- 快速分析:几秒内完成多维分析,不会错过机会
- 客观评分:给出一个客观的评分,避免情绪干扰
第四阶段:涨停股决策辅助
WorkBuddy可以辅助涨停股决策
涨停股是短线交易最关注的标的,但涨停股的决策最难——追还是不追?会不会炸板?
WorkBuddy可以快速分析涨停股的资金面情况:
deflimit_up_analysis(code):"""WorkBuddy分析涨停股"""# WorkBuddy读取涨停股池数据limit_path=DATA_DIR/'stock-a'/'涨停股池'withopen(limit_path,'r',encoding='utf-8')asf:limit_data=json.load(f)stock_limit=[itemforiteminlimit_dataifitem['股票代码']==code]ifnotstock_limit:returnNone# WorkBuddy提取涨停信息limit_time=stock_limit[0].get('涨停时间','')limit_times=int(stock_limit[0].get('涨停次数',0))limit_reason=stock_limit[0].get('涨停原因','')# WorkBuddy分析主力资金情况main_path=DATA_DIR/'stock-a'/'主力资金流向'withopen(main_path,'r',encoding='utf-8')asf:main_data=json.load(f)stock_main=[itemforiteminmain_dataifitem['股票代码']==code]main_inflow=float(stock_main[0].get('主力净流入(万元)',0))ifstock_mainelse0# WorkBuddy分析龙虎榜情况lb_path=DATA_DIR/'stock-a'/'龙虎榜'withopen(lb_path,'r',encoding='utf-8')asf:lb_data=json.load(f)on_lb=codein[item['股票代码']foriteminlb_data]# WorkBuddy给出综合判断analysis={'code':code,'limit_time':limit_time,'limit_times':limit_times,'limit_reason':limit_reason,'main_inflow':main_inflow,'on_lb':on_lb,'suggestion':''}# WorkBuddy判断:是否值得追iflimit_times>=2andmain_inflow>1000:analysis['suggestion']='🟢 强势涨停,主力认可,可关注'eliflimit_times>=2andmain_inflow<0:analysis['suggestion']='🟡 连板但主力流出,谨慎'eliflimit_time<'10:00'andmain_inflow>500:analysis['suggestion']='🟢 早盘涨停+资金流入,可关注'else:analysis['suggestion']='⚪ 观察,不急于操作'returnanalysis# WorkBuddy分析涨停股result=limit_up_analysis('000001')print(f"股票:{result['code']}")print(f"涨停时间:{result['limit_time']}")print(f"连板天数:{result['limit_times']}")print(f"主力流入:{result['main_inflow']:.0f}万元")print(f"龙虎榜:{'是'ifresult['on_lb']else'否'}")print(f"WorkBuddy建议:{result['suggestion']}")WorkBuddy会给出一个综合判断:
股票:000001 涨停时间:09:45 连板天数:2 主力流入:1500万元 龙虎榜:是 WorkBuddy建议:🟢 强势涨停,主力认可,可关注涨停股决策的逻辑
WorkBuddy对涨停股的决策逻辑:
| 情况 | 主力资金 | WorkBuddy建议 |
|---|---|---|
| 连板+主力流入 | >1000万 | 🟢 强势,可关注 |
| 连板+主力流出 | <0 | 🟡 谨慎 |
| 早盘涨停+主力流入 | >500万 | 🟢 强势,可关注 |
| 午后涨停+主力流出 | <0 | 🔴 风险较大 |
| 首板+龙虎榜机构买入 | >500万 | 🟢 机构认可,可关注 |
第五阶段:资金异动决策辅助
WorkBuddy可以辅助资金异动决策
看到主力资金大幅流入,要不要买?WorkBuddy可以快速分析资金异动的真实性:
deffund_anomaly_analysis(code):"""WorkBuddy分析资金异动"""# WorkBuddy读取主力资金流向main_path=DATA_DIR/'stock-a'/'主力资金流向'withopen(main_path,'r',encoding='utf-8')asf:main_data=json.load(f)stock_main=[itemforiteminmain_dataifitem['股票代码']==code]ifnotstock_main:returnNonemain_inflow=float(stock_main[0].get('主力净流入(万元)',0))main_ratio=float(stock_main[0].get('主力占比(%)',0))# WorkBuddy读取北向资金north_path=DATA_DIR/'stock-center'/'北向资金'withopen(north_path,'r',encoding='utf-8')asf:north_data=json.load(f)stock_north=[itemforiteminnorth_dataifitem['股票代码']==code]north_buy=float(stock_north[0].get('增持股数(万股)',0))ifstock_northelse0# WorkBuddy读取实时行情rt_path=DATA_DIR/'time'/'real'/codewithopen(rt_path,'r',encoding='utf-8')asf:rt_data=json.load(f)price=float(rt_data.get('p',0))change_pct=float(rt_data.get('pc',0))volume=float(rt_data.get('v',0))avg_volume=float(rt_data.get('avg_volume',1))# WorkBuddy判断:资金流入是否真实analysis={'code':code,'main_inflow':main_inflow,'main_ratio':main_ratio,'north_buy':north_buy,'change_pct':change_pct,'volume_ratio':volume/avg_volume,'suggestion':''}# WorkBuddy综合判断ifmain_inflow>1000andnorth_buy>10andchange_pct>3:analysis['suggestion']='🟢 主力+北向共同认可+股价上涨,可关注'elifmain_inflow>1000andchange_pct<0:analysis['suggestion']='🟡 资金流入但股价下跌,可能是被动买入'elifmain_inflow>1000andvolume/avg_volume<1.5:analysis['suggestion']='🟡 资金流入但量能未放大,持续性存疑'elifmain_inflow>1000andmain_ratio>50:analysis['suggestion']='🟢 主力占比高,主力认可度强'else:analysis['suggestion']='⚪ 观察,不急于操作'returnanalysis# WorkBuddy分析资金异动result=fund_anomaly_analysis('000001')print(f"股票:{result['code']}")print(f"主力流入:{result['main_inflow']:.0f}万元")print(f"主力占比:{result['main_ratio']:.2f}%")print(f"北向增持:{result['north_buy']:.0f}万股")print(f"涨幅:{result['change_pct']:.2f}%")print(f"量能比:{result['volume_ratio']:.1f}倍")print(f"WorkBuddy建议:{result['suggestion']}")WorkBuddy会给出一个综合判断:
股票:000001 主力流入:1500万元 主力占比:3.5% 北向增持:20万股 涨幅:4.5% 量能比:2.3倍 WorkBuddy建议:🟢 主力+北向共同认可+股价上涨,可关注资金异动决策的逻辑
WorkBuddy对资金异动的决策逻辑:
| 情况 | 条件 | WorkBuddy建议 |
|---|---|---|
| 真实流入 | 主力流入+北向增持+股价上涨 | 🟢 可关注 |
| 被动买入 | 主力流入+股价下跌 | 🟡 谨慎 |
| 持续性存疑 | 主力流入+量能未放大 | 🟡 观察 |
| 主力认可度高 | 主力流入+主力占比>50% | 🟢 可关注 |
第六阶段:龙虎榜决策辅助
WorkBuddy可以辅助龙虎榜决策
龙虎榜是游资和机构动向的公开披露,但龙虎榜的决策也很难——跟还是不跟?是机构买的还是游资买的?
WorkBuddy可以快速分析龙虎榜的买入方情况:
deflonghubang_analysis(code):"""WorkBuddy分析龙虎榜"""# WorkBuddy读取龙虎榜数据lb_path=DATA_DIR/'stock-a'/'龙虎榜'withopen(lb_path,'r',encoding='utf-8')asf:lb_data=json.load(f)stock_lb=[itemforiteminlb_dataifitem['股票代码']==code]ifnotstock_lb:returnNoneorg_buy=float(stock_lb[0].get('机构净买入(万元)',0))hot_buy=float(stock_lb[0].get('游资净买入(万元)',0))# WorkBuddy读取实时行情rt_path=DATA_DIR/'time'/'real'/codewithopen(rt_path,'r',encoding='utf-8')asf:rt_data=json.load(f)change_pct=float(rt_data.get('pc',0))# WorkBuddy判断:买入方情况analysis={'code':code,'org_buy':org_buy,'hot_buy':hot_buy,'change_pct':change_pct,'suggestion':''}# WorkBuddy综合判断iforg_buy>1000andhot_buy>1000:analysis['suggestion']='🟢 机构+游资共同买入,强信号'eliforg_buy>1000:analysis['suggestion']='🟢 机构买入,中长期看好'elifhot_buy>2000:analysis['suggestion']='🟡 游资大买,短期波动大'elifhot_buy>0andorg_buy<0:analysis['suggestion']='🟡 游资买+机构卖,风险较大'else:analysis['suggestion']='⚪ 观察,不急于操作'returnanalysis# WorkBuddy分析龙虎榜result=longhubang_analysis('000001')print(f"股票:{result['code']}")print(f"机构买入:{result['org_buy']:.0f}万元")print(f"游资买入:{result['hot_buy']:.0f}万元")print(f"WorkBuddy建议:{result['suggestion']}")WorkBuddy会给出一个综合判断:
股票:000001 机构买入:1500万元 游资买入:800万元 WorkBuddy建议:🟢 机构+游资共同买入,强信号龙虎榜决策的逻辑
WorkBuddy对龙虎榜的决策逻辑:
| 情况 | 条件 | WorkBuddy建议 |
|---|---|---|
| 最强信号 | 机构+游资共同买入 | 🟢 强信号 |
| 中长期看好 | 机构买入 | 🟢 可关注 |
| 短期波动大 | 游资大买 | 🟡 谨慎 |
| 风险较大 | 游资买+机构卖 | 🔴 风险较大 |
第七阶段:踩坑与优化
教训一:WorkBuddy评分不能直接当买卖信号
WorkBuddy的评分只是参考,不能直接当买卖信号。评分高的股票,也要结合盘面、情绪、大盘环境综合判断。
教训二:决策最终靠自己
WorkBuddy可以帮你快速分析,但最终的买卖决策还是靠自己。WorkBuddy是工具,不是圣杯。
教训三:要不断优化评分逻辑
市场风格在变,评分逻辑也要调整。我每隔一段时间就会优化WorkBuddy的评分逻辑,调整权重和阈值。
总结:从手动决策到WorkBuddy辅助
用WorkBuddy结合本地数据做决策辅助的这段时间,我的决策质量提升了一个量级:
之前:手动决策
- 几秒内犹豫,容易冲动
- 无法全面考虑多个维度
- 容易追高或踏空
现在:WorkBuddy辅助决策
- WorkBuddy几秒内完成多维分析
- WorkBuddy给出客观评分和建议
- 决策更理性,质量更高
从"拍脑袋决策"到"WorkBuddy辅助决策",交易质量明显提升。
给同路人的建议
如果你也想用WorkBuddy做决策辅助,建议从这几步开始:
- 确定决策维度:主力资金、北向资金、龙虎榜、涨停股?
- 设定评分逻辑:每个维度权重多少?阈值多少?
- 明确决策边界:WorkBuddy只是辅助,决策靠自己
把这些问题想清楚,再构建你的WorkBuddy辅助决策体系。决策辅助是工具,你的交易逻辑才是核心。
以上内容仅供交流学习,不构成投资建议。股市有风险,入市需谨慎。