|
@@ -15,7 +15,7 @@ from feapder.utils.tools import get_md5
|
|
|
from .bloomfilter import BloomFilter, ScalableBloomFilter
|
|
|
from .expirefilter import ExpireFilter
|
|
|
from .litefilter import LiteFilter
|
|
|
-from .redisfilter import RedisFilter, RedisMultiFilter
|
|
|
+from .redisfilter import RedisFilter, MultiRedisFilter
|
|
|
|
|
|
|
|
|
class Dedup:
|
|
@@ -24,7 +24,7 @@ class Dedup:
|
|
|
ExpireFilter = 3
|
|
|
LiteFilter = 4
|
|
|
RedisFilter = 5
|
|
|
- RedisMultiFilter = 6
|
|
|
+ MultiRedisFilter = 6
|
|
|
|
|
|
def __init__(self, filter_type: int = BloomFilter, to_md5: bool = True, **kwargs):
|
|
|
if filter_type == Dedup.ExpireFilter:
|
|
@@ -51,9 +51,9 @@ class Dedup:
|
|
|
redis_url=kwargs.get("redis_url"),
|
|
|
expire_time=kwargs.get("expire_time")
|
|
|
)
|
|
|
- elif filter_type == Dedup.RedisMultiFilter:
|
|
|
- self.dedup = RedisMultiFilter(
|
|
|
- redisdb_conf=kwargs.get("redisdb_conf"),
|
|
|
+ elif filter_type == Dedup.MultiRedisFilter:
|
|
|
+ self.dedup = MultiRedisFilter(
|
|
|
+ config=kwargs.get("config"),
|
|
|
expire_time=kwargs.get("expire_time")
|
|
|
)
|
|
|
else:
|