|
@@ -146,7 +146,7 @@ class ProxyPoolServer(BaseProxyPool, threading.Thread):
|
|
elif pk == 2:
|
|
elif pk == 2:
|
|
self.redis_db.rpush(self.lst_name_2, host)
|
|
self.redis_db.rpush(self.lst_name_2, host)
|
|
|
|
|
|
- logger.debug(f"添加代理|{host}")
|
|
|
|
|
|
+ logger.info(f"添加代理|{host}")
|
|
|
|
|
|
def del_proxy(self, proxy):
|
|
def del_proxy(self, proxy):
|
|
host = get_host(proxy['proxies'], self.scheme)
|
|
host = get_host(proxy['proxies'], self.scheme)
|
|
@@ -160,7 +160,7 @@ class ProxyPoolServer(BaseProxyPool, threading.Thread):
|
|
|
|
|
|
n0 = self.redis_db.lrem(self.lst_name, 0, host) # 移除所有匹配的元素
|
|
n0 = self.redis_db.lrem(self.lst_name, 0, host) # 移除所有匹配的元素
|
|
self.redis_db.hdel(self.tab_name, host)
|
|
self.redis_db.hdel(self.tab_name, host)
|
|
- logger.debug(f"移除代理|{host}|{n1 + n0}")
|
|
|
|
|
|
+ logger.info(f"移除代理|{host}|{n1 + n0}")
|
|
|
|
|
|
def update_proxy(self, proxy, success):
|
|
def update_proxy(self, proxy, success):
|
|
"""
|
|
"""
|