From fea5d948ae0c197f859f427596a85cb8cf82d389 Mon Sep 17 00:00:00 2001 From: zhaoxiangpeng <1943364377@qq.com> Date: Thu, 4 Dec 2025 16:30:52 +0800 Subject: [PATCH] =?UTF-8?q?add:=E5=A2=9E=E5=8A=A0=E5=BC=82=E5=B8=B8?= =?UTF-8?q?=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- science_article_add/science_article_add/pipelines/duptodo.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/science_article_add/science_article_add/pipelines/duptodo.py b/science_article_add/science_article_add/pipelines/duptodo.py index 83c630a..e09d116 100644 --- a/science_article_add/science_article_add/pipelines/duptodo.py +++ b/science_article_add/science_article_add/pipelines/duptodo.py @@ -73,6 +73,8 @@ class DupTodoPipeline(MongoDBUtils): raise DropItem('⏳ 已存在的item: \n[%s]' % ', '.join([x['third_id'] for x in items])) insert_result = self._insert2db(datas, item_type) affect_count = len(insert_result.inserted_ids) + except DropItem as drop_item: + logger.warning("Filter item: %s", drop_item) except Exception as e: logger.error(f"❌ 插入 %s 失败 %s 条: {e}" % (item_type, item_count)) else: