This commit is contained in:
vn.py 2017-12-02 21:46:05 +08:00
parent b1fff2765e
commit bd7c6082b4

View File

@ -234,8 +234,14 @@ class DrEngine(object):
while self.active:
try:
dbName, collectionName, d = self.queue.get(block=True, timeout=1)
flt = {'datetime': d['datetime']}
self.mainEngine.dbUpdate(dbName, collectionName, d, flt, True)
# 这里采用MongoDB的update模式更新数据在记录tick数据时会由于查询
# 过于频繁导致CPU占用和硬盘读写过高后系统卡死因此不建议使用
#flt = {'datetime': d['datetime']}
#self.mainEngine.dbUpdate(dbName, collectionName, d, flt, True)
# 使用insert模式更新数据可能存在时间戳重复的情况需要用户自行清洗
self.mainEngine.dbInsert(dbName, collectionName, d)
except Empty:
pass