From ff0dffb36f607192764a573dab64f825f554ebd0 Mon Sep 17 00:00:00 2001 From: wuhao <15392746632@qq.com> Date: Fri, 11 Dec 2020 11:56:49 +0800 Subject: [PATCH] =?UTF-8?q?=E8=BF=87=E6=BB=A4=E6=9F=A5=E8=AF=A2=E6=97=B6?= =?UTF-8?q?=E9=97=B4=E6=88=B3=E7=9B=B8=E7=AD=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- task/summary_func.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/task/summary_func.py b/task/summary_func.py index 73e491e..4b35204 100644 --- a/task/summary_func.py +++ b/task/summary_func.py @@ -43,7 +43,7 @@ class SummaryFunc(Task): data = model.dict() bulk_data.append(UpdateOne({'_id': data['_id']}, {'$set': data}, upsert=True)) except Exception as e: - # logger.error(f'ftype {item["ftype"]} msg:{e}') - pass + logger.error(f'ftype {item["ftype"]} msg:{e}') + # pass self.remote_db[self.task_name].bulk_write(bulk_data, ordered=False) self.set_cursor(cursor_st=ts['cursor_st'], cursor_et=ts['cursor_et'])