|
@@ -90,9 +90,11 @@ class ItemBuffer(threading.Thread):
|
|
|
if isinstance(item, Item):
|
|
|
# 入库前的回调
|
|
|
item.pre_to_db()
|
|
|
+ if item.dont_save:
|
|
|
+ # 不保存数据
|
|
|
+ return
|
|
|
|
|
|
- if getattr(item, "save", True): # save=False 不推送入库
|
|
|
- self._items_queue.put(item)
|
|
|
+ self._items_queue.put(item)
|
|
|
|
|
|
def flush(self):
|
|
|
try:
|