From fc7d7ee8d704121c2aaf229b05a13c511d75d246 Mon Sep 17 00:00:00 2001 From: pengtao Date: Tue, 8 Oct 2019 15:49:35 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E7=88=AC=E8=99=AB=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E5=86=99=E5=85=A5=E6=95=B0=E6=95=B0=E8=84=9A=E6=9C=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- taptap/collect_mongodb.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/taptap/collect_mongodb.py b/taptap/collect_mongodb.py index 38f9f1a..d4219a9 100644 --- a/taptap/collect_mongodb.py +++ b/taptap/collect_mongodb.py @@ -115,6 +115,10 @@ class CollectMongo(): def write2ss(self, data): event_name = self.item.get('event_name') run_false = False + try: + nums = len(data) + except: + nums = 0 for line in data: if line: for key in line.keys(): @@ -150,7 +154,7 @@ class CollectMongo(): log.error("write {}_{} event error! {}\n".format(event_name, self.tgaid, line)) run_false = True if not run_false: - log.info("write {}_{} event success！\n".format(event_name, self.tgaid)) + log.info("write {}_{} num={} success！\n".format(event_name, self.tgaid, nums)) def run(self): @@ -159,6 +163,7 @@ class CollectMongo(): def read_mongo(start_date, end_date): + print(f"start ={start_date},end={end_date}") all_type = [] reptile_4_1 = {} reptile_4_1['db'] = "taptap"