diff --git a/examples/HistDataCollector/HD_setting.json b/examples/HistDataCollector/HD_setting.json deleted file mode 100644 index 3294e417..00000000 --- a/examples/HistDataCollector/HD_setting.json +++ /dev/null @@ -1,15 +0,0 @@ -{ - "working": true, - - "tick": - [ - ["700", "IB", "SEHK", "HKD", "股票"], - ["USD.JPY", "IB", "IDEALPRO", "JPY", "外汇"] - ], - - "bar": - [ - ["700", "IB", "SEHK", "HKD", "股票"], - ["USD.JPY", "IB", "IDEALPRO", "JPY", "外汇"] - ] -} \ No newline at end of file diff --git a/examples/HistDataCollector/runHistDataCollector.py b/examples/HistDataCollector/runHistDataCollector.py deleted file mode 100644 index 604e20a9..00000000 --- a/examples/HistDataCollector/runHistDataCollector.py +++ /dev/null @@ -1,105 +0,0 @@ -# encoding: UTF-8 - -import multiprocessing -from time import sleep -from datetime import datetime, time - -from vnpy.event import EventEngine2 -from vnpy.trader.vtEvent import EVENT_LOG, EVENT_ERROR -from vnpy.trader.vtEngine import MainEngine, LogEngine -from vnpy.trader.gateway import ibGateway -from vnpy.trader.app import dataRecorder - - -#---------------------------------------------------------------------- -def processErrorEvent(event): - """ - 处理错误事件 - 错误信息在每次登陆后,会将当日所有已产生的均推送一遍,所以不适合写入日志 - """ - error = event.dict_['data'] - print u'错误代码:%s,错误信息:%s' %(error.errorID, error.errorMsg) - -#---------------------------------------------------------------------- -def runChildProcess(): - """子进程运行函数""" - print '-'*20 - - # 创建日志引擎 - le = LogEngine() - le.setLogLevel(le.LEVEL_DEBUG) - le.addConsoleHandler() - le.info(u'启动行情记录运行子进程') - - ee = EventEngine2() - le.info(u'事件引擎创建成功') - - me = MainEngine(ee) - me.addGateway(ibGateway) - me.addApp(histDataCollector) - le.info(u'主引擎创建成功') - - ee.register(EVENT_LOG, le.processLogEvent) - ee.register(EVENT_ERROR, processErrorEvent) - le.info(u'注册日志事件监听') - - me.connect('IB') - le.info(u'连接IB接口') - - while True: - sleep(1) - -#---------------------------------------------------------------------- -def runParentProcess(): - """父进程运行函数""" - # 创建日志引擎 - le = LogEngine() - le.setLogLevel(le.LEVEL_INFO) - le.addConsoleHandler() - le.info(u'启动HistData守护父进程') - - DAY_START = time(8, 57) # 日盘启动和停止时间 - DAY_END = time(15, 18) - NIGHT_START = time(20, 57) # 夜盘启动和停止时间 - NIGHT_END = time(2, 33) - - p = None # 子进程句柄 - - while True: - currentTime = datetime.now().time() - recording = False - - # 判断当前处于的时间段 - if ((currentTime >= DAY_START and currentTime <= DAY_END) or - (currentTime >= NIGHT_START) or - (currentTime <= NIGHT_END)): - recording = True - - # 过滤周末时间段:周六全天,周五夜盘,周日日盘 - if ((datetime.today().weekday() == 6) or - (datetime.today().weekday() == 5 and currentTime > NIGHT_END) or - (datetime.today().weekday() == 0 and currentTime < DAY_START)): - recording = False - - recording = True - # 记录时间则需要启动子进程 - if recording and p is None: - le.info(u'启动子进程') - p = multiprocessing.Process(target=runChildProcess) - p.start() - le.info(u'子进程启动成功') - - # 非记录时间则退出子进程 - if not recording and p is not None: - le.info(u'关闭子进程') - p.terminate() - p.join() - p = None - le.info(u'子进程关闭成功') - - sleep(5) - - -if __name__ == '__main__': - #runChildProcess() - runParentProcess()