Ver Fonte

fix bug:request去重未生效错误修复

dongzhaorui há 2 anos atrás
pai
commit
01090cb18b
1 ficheiros alterados com 3 adições e 4 exclusões
  1. 3 4
      FworkSpider/feapder/dedup/swordfishfilter.py

+ 3 - 4
FworkSpider/feapder/dedup/swordfishfilter.py

@@ -58,7 +58,7 @@ class SwordFishFilter(BaseFilter):
         """
         添加数据
         @param keys: 检查关键词在redis_cluster中是否存在,支持列表批量
-        @return: list / 单个值
+        @return: list / 单个值(如果数据已存在 返回 False 否则返回 True, 可以理解为是否添加成功)
         """
         is_list = isinstance(keys, list)
         keys = keys if is_list else [keys]
@@ -67,10 +67,9 @@ class SwordFishFilter(BaseFilter):
         is_added = []
         for key in encrypt_keys:
             if not self.exists(key):
-                is_added.append(
-                    self.redis_cluster.set(self._prefix + key, 1, ex=self._ex))
+                is_added.append(self.redis_cluster.set(self._prefix + key, 1, ex=self._ex))
             else:
-                is_added.append(True)
+                is_added.append(False)
 
         return is_added if is_list else is_added[0]