在示范策略代码中没有找到关于实时数据推送给策略的入口,请问策略如何接收实时实盘行情,示范策略如下。
def onInit(self):
"""初始化策略(必须由用户继承实现)"""
self.writeCtaLog(u'双EMA演示策略初始化,走这里初始化')
initData = self.loadBar(self.initDays)
for bar in initData:
self.onBar(bar)
self.putEvent()
#----------------------------------------------------------------------
def onStart(self):
"""启动策略(必须由用户继承实现)"""
self.writeCtaLog(u'双EMA演示策略启动,走这里!')
self.putEvent()
从代码初始化可以看到把数据库中查到的数据推给了onBar,并由onBar发出买入和卖出信号,但onStart中并没有订阅实时行情并把实时行情推给onBar,请问是不是我由看遗漏的代码,如果自己实现订阅行情,并将订阅行情Tick数据转换为5分钟K线同送给onBar,之后写入数据库中应该怎么实现。