這篇文章給大家介紹VNPY單品種期貨的網(wǎng)格交易策略的實(shí)現(xiàn)是怎樣的，內(nèi)容非常詳細(xì)，感興趣的小伙伴們可以參考借鑒，希望對(duì)大家能有所幫助。
這里做了單品種期貨網(wǎng)格交易策略實(shí)現(xiàn)。
當(dāng)bar.close在通道中時(shí)候，下個(gè)bar打到上軌開多單，打到下軌空單。
這里采用了均量交易法,就是每筆下單手?jǐn)?shù)都是一樣，并非金字塔式下單。
有多單時(shí)候，突破上線加多單，突破下線情況清空所有多單，當(dāng)多單到達(dá)定義的大手?jǐn)?shù)不再下單
為防止在一個(gè)線上下波動(dòng)，造成重復(fù)開平倉(cāng)情況，如果突破平倉(cāng)，比如平多單，后面n個(gè)bar不能再開多單，只能開空單；反之平空單后，
現(xiàn)在這個(gè)策略很粗糙，只做實(shí)現(xiàn)邏輯分析，可以回測(cè)，考慮涉及倉(cāng)位控制，別實(shí)盤。
點(diǎn)擊(此處)折疊或打開
# encoding: UTF-8
from __future__ import division
from vnpy.trader.vtGateway import *
from math import isnan
import numpy as np
import pandas as pd
from vnpy.trader.app.ctaStrategy.ctaTemplate import (CtaTemplate, TargetPosTemplate,
BarGenerator,
ArrayManager)
class GridStrategy(CtaTemplate):
className = 'GridStrategy'
author = u'BillyZhang'
# 策略參數(shù)
historyBars = 200 # 歷史數(shù)據(jù)大小，用來確定網(wǎng)格基準(zhǔn)線
initDays = 20 # 初始化數(shù)據(jù)所用的天數(shù)，隨著歷史數(shù)據(jù)大小要改變
gridlines = 10 # 網(wǎng)格線數(shù)量，單邊數(shù)量
ordersize = 10 # 大持倉(cāng)數(shù)量
order = 1 # 每次下單手?jǐn)?shù)
barMins = 30 #bar的時(shí)間
frozenBars = 1 #平倉(cāng)后，frozenBars個(gè)bar不再開反向單
atrWindow = 30 # ATR窗口數(shù)
slMultiplier = 5.0 # 計(jì)算止損距離的乘數(shù)
# 基本變量
upline = 0 #當(dāng)前上線
bottomline = 0 #當(dāng)前下線
frozen = 0 #當(dāng)前是否凍結(jié)開反向單
intraTradeHigh = 0
intraTradeLow = 0
atrValue = 0
# 參數(shù)列表，保存了參數(shù)的名稱
paramList = ['name',
'className',
'author',
'vtSymbol',
'historyBars'
'initDays',
'gridlines',
'barMins',
'order',
'ordersize',
'atrWindow',
'slMultiplier'
]
# 變量列表，保存了變量的名稱
varList = ['inited',
'trading',
'pos',
'frozen',
'upline',
'bottomline'
'atrValue']
# 同步列表，保存了需要保存到數(shù)據(jù)庫(kù)的變量名稱
syncList = ['pos',
'frozen']
# ----------------------------------------------------------------------
def __init__(self, ctaEngine, setting):
"""Constructor"""
super(GridStrategy, self).__init__(ctaEngine, setting)
self.bg = BarGenerator(self.onBar, self.barMins, self.onXminBar) # 創(chuàng)建K線合成器對(duì)象
self.am = ArrayManager(self.historyBars + 50)
# ----------------------------------------------------------------------
def onInit(self):
"""初始化策略（必須由用戶繼承實(shí)現(xiàn)）"""
self.writeCtaLog(u'%s策略初始化' % self.name)
# 載入歷史數(shù)據(jù)，并采用回放計(jì)算的方式初始化策略數(shù)值
initData = self.loadBar(self.initDays)
for bar in initData:
self.onBar(bar)
self.putEvent()
def onStart(self):
"""啟動(dòng)策略（必須由用戶繼承實(shí)現(xiàn)）"""
self.writeCtaLog(u'%s策略啟動(dòng)' % self.name)
self.putEvent()
def onStop(self):
"""停止策略（必須由用戶繼承實(shí)現(xiàn)）"""
self.writeCtaLog(u'%s策略停止' % self.name)
self.putEvent()
# -----------------------------------------------------------------------
def onXminBar(self, bar):
"""收到X分鐘K線"""
# 全撤之前發(fā)出的委托
self.cancelAll()
# 保存K線數(shù)據(jù)
am = self.am
am.updateBar(bar)
if not am.inited:
return
# 這里采用了均量交易法,就是每筆。
# 空倉(cāng)時(shí)候，每次突破上線是開多單，突破下線是開空單；
# 有多單時(shí)候，突破上線加多單，突破下線情況清空所有多單，
# 有空單時(shí)候，突破下線加空單，突破上線清空所有空單，
# 為防止在一個(gè)線上下波動(dòng)，造成重復(fù)開平倉(cāng)情況，如果突破平倉(cāng)，比如平多單，后面n個(gè)bar不能再開多單，只能開空單；反之平空單后，
# 后面n個(gè)bar只能開多單。
# 計(jì)算網(wǎng)格,返回通道隊(duì)列, 再算出當(dāng)前點(diǎn)位所在通道，0為最下通道，2*self.gridlines - 1為最上通道
baseline = self.am.sma(self.historyBars)
# 過去300的標(biāo)準(zhǔn)差，按照頂一個(gè)gridlines取整做出一個(gè)隊(duì)列
intervallist = baseline+ np.array([n * 1.00 / self.gridlines for n in range(-1 * self.gridlines, self.gridlines + 1)]) * self.am.std(self.historyBars)
griploc = pd.cut([bar.close], intervallist, labels=[nx for nx in range(0,2*self.gridlines)])[0]
# 如果返回為nan，說明現(xiàn)在bar.close在標(biāo)準(zhǔn)差范圍以外，如果沒有倉(cāng)位，先不處理；如果有，按照ATR波動(dòng)移動(dòng)止盈
if isnan(griploc):
# 持有多頭倉(cāng)位
if self.pos > 0:
self.intraTradeHigh = max(self.intraTradeHigh, bar.high)
self.intraTradeLow = bar.low
self.longStop = self.intraTradeHigh - self.atrValue * self.slMultiplier
self.sell(self.longStop, abs(self.pos), True)
# 持有空頭倉(cāng)位
elif self.pos < 0:
self.intraTradeHigh = bar.high
self.intraTradeLow = min(self.intraTradeLow, bar.low)
self.shortStop = self.intraTradeLow + self.atrValue * self.slMultiplier
self.cover(self.shortStop, abs(self.pos), True)
return
#返回上下線：
self.upline = intervallist[griploc + 1]
self.bottomline = intervallist[griploc]
# 空倉(cāng)時(shí)候，每次突破上線是開多單，突破下線是開空單；
# 如果此時(shí)在最下一個(gè)通道，此時(shí)只掛往上的多單, 如果在最上面通道，此時(shí)只掛往下空單；如果在中間的，則同時(shí)開上下單
if self.pos == 0:
if griploc ==0:
self.buy(self.upline, self.order, True)
elif griploc == 2*self.gridlines - 1:
self.short(self.bottomline,self.order,True)
else:
#此時(shí)如果frozen 為0， 直接開上下單：
if self.frozen == 0:
self.buy(self.upline, self.order, True)
self.short(self.bottomline, self.order, True)
#此時(shí)如果大于0，只能開空單，如果小于0，只能開多單
elif self.frozen > 0:
self.frozen = self.frozen -1
self.short(self.bottomline, self.order, True)
elif self.frozen < 0:
self.frozen = self.frozen + 1
self.buy(self.upline, self.order, True)
#如果持有多倉(cāng)時(shí)候，如果在中間通道，同時(shí)開上下單；如果最高點(diǎn)位不再開單，突破大標(biāo)準(zhǔn)差高點(diǎn)，
elif self.pos > 0:
# 在最下通道不可能有多單，只用考量在中間段,pos 小于ordersize可以增多倉(cāng)，否則只能向下平倉(cāng)；和最高段情況,最高段設(shè)置往下平倉(cāng)，
if griploc == 2*self.gridlines - 1:
self.intraTradeHigh = bar.high
self.sell(self.bottomline, abs(self.pos), True)
else:
if abs(self.pos) < self.ordersize:
self.buy(self.upline, self.order, True)
self.sell(self.bottomline, abs(self.pos), True)
else:
self.sell(self.bottomline, abs(self.pos), True)
elif self.pos < 0:
# 最上通道通道不可能有空單，只用考慮中間段，和最低檔情況
if griploc == 0:
self.intraTradeLow = bar.low
self.cover(self.upline,abs(self.pos),True)
else:
if abs(self.pos) < self.ordersize:
self.cover(self.upline, abs(self.pos),True)
self.sell(self.bottomline, self.order, True)
else:
self.cover(self.upline, abs(self.pos), True)
# ----------------------------------------------------------------------
def onTick(self, tick):
"""收到行情TICK推送（必須由用戶繼承實(shí)現(xiàn)）"""
self.bg.updateTick(tick)
# ----------------------------------------------------------------------
def onBar(self, bar):
"""收到Bar推送（必須由用戶繼承實(shí)現(xiàn)）"""
self.bg.updateBar(bar)
# ----------------------------------------------------------------------
def onOrder(self, order):
"""收到委托推送"""
pass
# ----------------------------------------------------------------------
def onTrade(self, trade):
# 發(fā)出狀態(tài)更新事件
# 如果收到成交，清空所有掛單
self.cancelAll()
# 如果交易多頭方向，且現(xiàn)在倉(cāng)位為0，則應(yīng)該是空頭平倉(cāng)，不再開空單
if trade.direction == DIRECTION_LONG and self.pos == 0:
self.frozen = -1* self.frozen
# 如果交易空頭方向，且現(xiàn)在倉(cāng)位為0，則應(yīng)該是多平倉(cāng)，不再開多單
elif trade.direction == DIRECTION_SHORT and self.pos == 0:
self.frozen = self.frozen
self.putEvent()
# ----------------------------------------------------------------------
def onStopOrder(self, so):
"""停止單推送"""
pass
關(guān)于VNPY單品種期貨的網(wǎng)格交易策略的實(shí)現(xiàn)是怎樣的就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò)，可以把它分享出去讓更多的人看到。
重慶分公司
重慶分公司
