senset/vnpy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[Fix]Close #792

Browse Source
This commit is contained in:
vn.py 2018-05-07 22:39:25 +08:00
parent 5438df5c45
commit 00f9da4c68
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
examples/QuantosDataService/dataService.py
View File

@ -50,7 +50,12 @@ def generateVtBar(row):
bar.symbol = symbol bar.symbol = symbol
bar.exchange = exchangeMapReverse[exchange] bar.exchange = exchangeMapReverse[exchange]
bar.vtSymbol = '.'.join([bar.symbol, bar.exchange])
if bar.exchange in ['SSE', 'SZSE']:
bar.vtSymbol = '.'.join([bar.symbol, bar.exchange])
else:
bar.vtSymbol = bar.symbol
bar.open = row['open'] bar.open = row['open']
bar.high = row['high'] bar.high = row['high']
bar.low = row['low'] bar.low = row['low']
@ -92,7 +97,7 @@ def downMinuteBarBySymbol(api, vtSymbol, startDate, endDate=''):
cl = db[vtSymbol] cl = db[vtSymbol]
else: else:
cl = db[code] cl = db[code]
cl.ensure_index([('datetime', ASCENDING)], unique=True) # 添加索引 cl.ensure_index([('datetime', ASCENDING)], unique=True) # 添加索引
dt = datetime.strptime(startDate, '%Y%m%d') dt = datetime.strptime(startDate, '%Y%m%d')