update:更新redis过滤器配置

FworkSpider/feapder/dedup/redisfilter.py

@@ -17,17 +17,16 @@ class RedisFilter(BaseFilter):
     redis_db = None
 
     def __init__(self, ip_ports=None, redis_url=None, expire_time=None):
-        if not self.__class__.redis_db:
-            if isinstance(ip_ports, list) and len(ip_ports) > 1:
-                self.__class__.redis_db = RedisDB(
-                    ip_ports=ip_ports,
-                    decode_responses=True,
-                    user_pass='',
-                )  # 集群
-            elif redis_url:
-                self.__class__.redis_db = RedisDB(redis_url=redis_url)  # 单机
-            else:
-                self.__class__.redis_db = RedisDB(ip_ports=ip_ports)  # 单机
+        if isinstance(ip_ports, list) and len(ip_ports) > 1:
+            self.__class__.redis_db = RedisDB(
+                ip_ports=ip_ports,
+                user_pass='',
+                decode_responses=True,
+            )  # 集群
+        elif redis_url:
+            self.__class__.redis_db = RedisDB(redis_url=redis_url)  # 单机
+        else:
+            self.__class__.redis_db = RedisDB(ip_ports=ip_ports)  # 单机
 
         self._ex = expire_time or 86400 * 365 * 2  # 2年 = 86400 * 365 * 2
         self._prefix1 = 'list_'