python 主力资金_真正的主力进场加仓指标源码
import numpy as np
def initialize(context):
g.up_price = {} #向上碎形最高价
g.low_price = {} #向下碎形最低价
g.up_fractal_exists = {} #判断有效向上碎形
g.down_fractal_exists = {} #判断有效向下碎形
g.AO_index = {} #存放连续的AO指标数据
g.cal_AC_index = {} #计算AC指标中转存储
g.AC_index = {} #存放连续的AC指标数据
g.amount = {} #满仓仓位
g.stock = get_index_stocks('000300.XSHG')
g.buy_stock = []
set_benchmark('000300.XSHG')
g.month = context.current_dt.month
run_monthly(select_universe,1,'open')
#重置全局变量
def reset_global():
g.up_price = {} #向上碎形最高价
g.low_price = {} #向下碎形最低价
g.up_fractal_exists = {} #判断有效向上碎形
g.down_fractal_exists = {} #判断有效向下碎形
g.AO_index = {} #存放连续的AO指标数据
g.cal_AC_index = {} #计算AC指标中转存储
g.AC_index = {} #存放连续的AC指标数据
g.amount = {} #满仓仓位
g.buy_stock = []
def initial_stock_global(stock):
g.up_price[stock] = 0
g.low_price[stock] = 0
g.up_fractal_exists[stock] = False
g.down_fractal_exists[stock] = False #判断有效向下碎形
g.AO_index[stock] = [0] #存放连续的AO指标数据
g.cal_AC_index[stock] = [0] #计算AC指标中转存储
g.AC_index[stock] = [0] #存放连续的AC指标数据
g.amount[stock] = 0 #满仓仓位
#轮换选股后清空持仓
def reset_position(context):
for stock in g.buy_stock:
order_target(stock,0)
log.info("sell %s for reset position"%stock)
#选股
def select_universe(context):
#每三个月操作一次
month = context.current_dt.month
if month%6 != g.month%6:
return
#清空全局变量
reset_position(context)
reset_global()
hist = history(30,'1d','close',g.stock,df = False)
for stock in g.stock:
if is_sleeping_alligator(stock,hist,20):
g.buy_stock.append(stock)
#初始化该股票全局变量
initial_stock_global(stock)
print g.buy_stock
return None
#睡着的鳄鱼
def is_sleeping_alligator(stock,hist,nday):
for i in range(nday):
if is_struggle(stock,hist,i) == False:
return False
return True
#均线纠缠,BRG三线非常接近
def is_struggle(stock,hist,delta):
blue_line = hist[stock][-21-delta:-8-delta].mean()
red_line = hist[stock][-13-delta:-5-delta].mean()
green_line = hist[stock][-8-delta:-3-delta].mean()
if abs(blue_line/red_line-1)<0.02 and abs(red_line/green_line-1)<0.02:
return True
else:
return False
#判断 向上 或 向下 碎形
def is_fractal(stock,direction):
hist = history(5,'1d',direction,[stock],df = False)
if direction == 'high'\
and hist[stock][2] > hist[stock][0]\
and hist[stock][2] > hist[stock][1]\
and hist[stock][2] > hist[stock][3]\
and hist[stock][2] > hist[stock][4]:
g.up_price[stock] = hist[stock][2]
return True
elif direction == 'low'\
and hist[stock][2] < hist[stock][0]\
and hist[stock][2] < hist[stock][1]\
and hist[stock][2] < hist[stock][3]\
and hist[stock][2] < hist[stock][4]:
g.low_price[stock] = hist[stock][2]
return True
return False
#通过比较碎形与红线位置,判断碎形是否有效
def is_effective_fractal(stock, direction):
if is_fractal(stock,direction):
hist = history(13,'1d','close',[stock],df = False)
red_line = hist[stock][:-5].mean()
close_price = hist[stock][-1]
if direction == 'high':
if close_price > red_line:
g.up_fractal_exists[stock] = True
else:
g.up_fractal_exists[stock] = False
elif direction == 'low':
if close_price < red_line:
g.down_fractal_exists[stock] = True
else:
g.down_fractal_exists[stock] = False
#N日内最高价格的N日线
def nday_high_point(stock,n):
hist = history(2*n,'1d','high',[stock],df = False)[stock]
high_point = []
for i in range(n):
high_point.append(max(hist[-5-i:-1-i]))
return np.array(high_point).mean()
#N日内最低价格的N日线
def nday_low_point(stock,n):
hist = history(2*n,'1d','low',[stock],df = False)[stock]
low_point = []
for i in range(n):
low_point.append(max(hist[-5-i:-1-i]))
return np.array(low_point).mean()
#AO=5日内(最高-最低)/2的5日移动平均-34日内(最高-最低)/2的34日移动平均
def AO_index(stock):
g.AO_index[stock].append(nday_high_point(stock,5)/2 + nday_low_point(stock,5)/2\
- nday_high_point(stock,34)/2 - nday_low_point(stock,34)/2)
return None
#AO-AO的5日平均值的5日平均
def AC_index(stock):
AO_index(stock)
if len(g.AO_index[stock]) >= 5:
g.cal_AC_index[stock].append(g.AO_index[stock][-1] - np.array(g.AO_index[stock][-5:]).mean())
if len(g.cal_AC_index[stock]) >=5:
g.AC_index[stock].append(np.array(g.cal_AC_index[stock][-5:]).mean())
#判断序列n日上行
def is_up_going(alist,n):
if len(alist) < n:
return False
for i in range(n-1):
if alist[-(1+i)] <= alist[-(2+i)]:
return False
return True
#判断序列n日下行
def is_down_going(alist,n):
if len(alist) < n:
return False
for i in range(n-1):
if alist[-(1+i)] >= alist[-(2+i)]:
return False
return True
#碎形被突破
def active_fractal(stock,direction):
close_price = history(1,'1d','close',[stock],df=False)[stock][0]
if direction == 'up' and close_price > g.up_price[stock]:
return True
elif direction == 'down' and close_price < g.low_price[stock]:
return True
return False
#进场,初始仓位
def set_initial_position(stock,context):
close_price = history(1,'1d','close',[stock],df=False)[stock][0]
g.amount[stock] = context.portfolio.cash/close_price/len(g.buy_stock)*3
order(stock, g.amount[stock])
log.info("buying %s 股数为 %s"%(stock,g.amount[stock]))
g.down_fractal_exists[stock] = False
#卖出
def sell_all_stock(stock,context):
order_target(stock,0)
log.info("selling %s"%stock)
g.up_fractal_exists[stock] = False
#加仓
def adjust_position(stock,context,position):
order(stock,g.amount[stock]*position)
log.info("adjust position buying %s 股数为 %s"%(stock,g.amount[stock]*position))
# 计算股票前n日收益率
def security_return(days,security_code):
hist1 = attribute_history(security_code, days + 1, '1d', 'close',df=False)
security_returns = (hist1['close'][-1]-hist1['close'][0])/hist1['close'][0]
return security_returns
# 止损,根据前n日收益率
def conduct_nday_stoploss(context,security_code,days,bench):
if security_return(days,security_code)<= bench:
for stock in g.buy_stock:
order_target_value(stock,0)
log.info("Sell %s for stoploss" %stock)
return True
else:
return False
# 计算股票累计收益率(从建仓至今)
def security_accumulate_return(context,data,stock):
current_price = data[stock].price
cost = context.portfolio.positions[stock].avg_cost
if cost != 0:
return (current_price-cost)/cost
else:
return None
# 个股止损,根据累计收益
def conduct_accumulate_stoploss(context,data,stock,bench):
if security_accumulate_return(context,data,stock) != None\
and security_accumulate_return(context,data,stock) < bench:
order_target_value(stock,0)
log.info("Sell %s for stoploss" %stock)
return True
else:
return False
# 个股止盈,根据累计收益
def conduct_accumulate_stopwin(context,data,stock,bench):
if security_accumulate_return(context,data,stock) != None\
and security_accumulate_return(context,data,stock) > bench:
order_target_value(stock,0)
log.info("Sell %s for stopwin" %stock)
return True
else:
return False
def handle_data(context,data):
#大盘止损
if conduct_nday_stoploss(context,'000300.XSHG',3,-0.03):
return
for stock in g.buy_stock:
#个股止损
if conduct_accumulate_stopwin(context,data,stock,0.3)\
or conduct_accumulate_stoploss(context,data,stock,-0.1):
return
#计算AO,AC指标
AC_index(stock)
#空仓时,寻找机会入场
if context.portfolio.positions[stock].amount == 0:
#计算向上碎形
is_effective_fractal(stock,'high')
#有效向上碎形存在,并被突破,买入
if g.up_fractal_exists and active_fractal(stock,'up'):
close_price = history(5, '1d', 'close', [stock],df = False)
if is_up_going(g.AO_index[stock],5)\
and is_up_going(g.AC_index[stock],3)\
and is_up_going(close_price[stock],2):
set_initial_position(stock,context)
#有持仓时,加仓或离场
else:
#计算向下碎形
is_effective_fractal(stock,'low')
#出场条件1:有效向下碎形存在,并被突破,卖出
if g.down_fractal_exists and active_fractal(stock,'down'):
sell_all_stock(stock,context)
return
#出场条件2:
#加仓10%:AO,AC同时5日上行,且收盘价走高
# if is_up_going(g.AO_index[stock],5)\
# and is_up_going(g.AC_index[stock],3)\
# and is_up_going(close_price[stock],2):
# adjust_position(stock,context,0.1)
# #减仓10%:AO,AC同时3日下行,且收盘价走低
# if is_down_going(g.AO_index[stock],5)\
# and is_down_going(g.AC_index[stock],3)\
# and is_down_going(close_price[stock],2):
# adjust_position(stock,context,-0.1)
简要介绍
1.选股
选择沪深300指数成分股
沉睡的鳄鱼,RBG三线纠缠。(选择连续20交易日处于沉睡状态的股票,建立buy_stock池)
每6个月更新股票池
benchmark沪深300指数
2.入场
存在有效碎形
有效碎形被突破
AO指标连续5日上行
AC指标连续3日上行
收盘价高于前一日收盘价
按g.amount=总资金/股票池股数×乘数因子3买入。
3.止损&止盈
大盘3日累计收益率下跌3%,全部股票清仓
个股累计收益率(以成本价为基准)超过30%,全部卖出
个股累计收益率下跌10%,全部卖出
4.加仓&减仓(感觉用处不大,暂没有使用,源代码保留在注释里)
AO连续5日上行,AC连续3日上行加仓10%
AO连续5日下跌,AC连续3日下跌减仓10%
5.退出
存在有效向下碎形
向下碎形被突破
全部卖出
小结一下
关于组合仓位控制
股票池组合操作对于仓位控制的要求比较严格。目前这方面还没有太多系统的想法,包括建仓比例,调仓以及不同股票的仓位配置,资金利用效率等等。
举例:g.amount在赋值时,简单的认为根据(总资金/buy_stock股数)×乘数因子 对资金配比。乘数因子是避免不符合条件的股票太多导致仓位较低,影响资金利用效率。
个人感觉,可以根据市值、pe或则其他体现每只持仓股票差异的因素来进行仓位管理,这方面有好的建议的朋友可以留言一起探讨。
止损条件
止损和止盈条件纯属个人风格吧。也是每一个策略里必然会加上的。15年至今的回测结果来看,回撤控制的比较好。当然也就牺牲了一些较大获利的可能性。
python 主力资金_真正的主力进场加仓指标源码相关推荐
- 底量超顶量超级大黑马指标源码_求通达信顶底趋势指标源码
展开全部 顶底趋势指标(通达信) 此指标是我精心收藏的指标,无未来函数,62616964757a686964616fe4b893e5b19e31333262353334真正的好指标.图片演示在下面网址 ...
- 主力用计算机吸筹,主力进场买点 找主力吸筹提款 通达信副图指标 源码 贴图(图文)...
主力进场买点 找主力吸筹提款 通达信副图指标 源码 贴图 VARC:=LOW; VARD:=REF(LOW,1); VARE:=SMA(ABS(VARC-VARD),3,1)/SMA(MAX(VARC ...
- python qt gui快速编程_《PYTHON QT GUI快速编程 PYQT编程指南》源码
文件名大小更新时间 <PYTHON QT GUI快速编程 PYQT编程指南>源码\chap01\answers.txt9882007-06-27 <PYTHON QT GUI快速编程 ...
- python程序员专用壁纸_程序员炫技必备:用Python生成马赛克画!(文末附源码)...
原标题:程序员炫技必备:用Python生成马赛克画!(文末附源码) 源 | Python与数据分析文 | 强哥 大家知道马赛克画是什么吗?不是动作片里的马赛克哦~~ 马赛克画是一张由小图拼成的大图,本 ...
- 主力吸筹猛攻指标源码_通达信偷偷连续吸筹指标,主力吸筹猛攻指标源码
通达信偷偷连续吸筹指标,主力吸筹猛攻指标源码: C5周:CCI(25),COLORSTICK,COLORYELLOW; 生命CCI线:=CCI(84),COLORWHITE; 底部线:=-100.00 ...
- 分享Python采集的77个PHP整站程序源码
Python采集的77个PHP整站程序源码下载链接:百度网盘 请输入提取码 提取码:pdwa ULCms(Unlimited Cms) V1.0 RC Build 20080926 DiY-Page ...
- Python基于OpenCV的图像去雾算法[完整源码&部署教程]
1.图片识别 2.视频展示 [项目分享]Python基于OpenCV的图像去雾算法[完整源码&部署教程]_哔哩哔哩_bilibili 3.算法原理 图像增强算法常见于对图像的亮度.对比度.饱和 ...
- Python基于OpenCV监控老鼠蟑螂检测系统[完整源码&部署教程]
1.视频演示: [项目分享]Python基于OpenCV监控老鼠蟑螂检测系统[完整源码&部署教程]_哔哩哔哩_bilibili 2.图片演示: 3.明厨亮灶: 餐饮企业的厨房卫生状况一直饱受消 ...
- 九龙擒庄指标源码破译_九龙擒庄指标源码破译_破译股市密码
K线密码非原创(主图源码贴图) 您正在下载的是:破译K线密码非原创(主图源码贴图)破译K线密码其实就是趋势射线指标.本人认为是对趋势射线指标的用法作了很好的解释.3),L,3),L,0),7),H,7 ...
最新文章
- Ubuntu 14.04安装搜狗拼音linux版应该注意的问题
- 代码坏味道之非必要的
- 成功解决AttributeError: module ‘tensorflow‘ has no attribute ‘get_variable‘
- MyBatis框架 拦截器简单使用
- samp服务器信息获取,手把手教你写一个简单的服务器
- AMD CPU驱动被曝漏洞,可使 KASLR崩溃、密码泄露
- 慕课网仿去哪儿项目笔记--(三)-城市页面制作
- 2022级sdut知到/智慧树---c语言第一章测试题解
- 攻防世界 REVERSE 新手区/logmein
- Android安全测试
- EtherCAT主站SOEM函数详解---- ecx_readstate、ecx_writestate
- kotlin 仿照setOnclickListener写法
- 【uoj#311】[UNR #2]积劳成疾 dp
- 微信小程序 input 的 type属性 text、number、idcard、digit 区别
- python中怎么输入正斜杠,详解Python中的正斜杠与反斜杠
- Redis Redis Cluster 字段模糊匹配及删除
- 基于正交设计的折射反向学习樽海鞘群算法
- 【RVM预测】基于粒子群算法优化相关向量机RVM实现数据回归预测附matlab代码
- 半导体器件物理【14】非平衡过剩载流子 —— 非平衡少数载流子浓度 、附加电导、扩散电流、漂移电流、总电流
- 基于asp.net172电影视频点播分享网站