|
@@ -31,16 +31,13 @@ class SsdbClient(object):
|
|
|
验证后的代理存放在name为useful_proxy的hash中,key为代理的ip:port,value为一个计数,初始为1,每校验失败一次减1;
|
|
验证后的代理存放在name为useful_proxy的hash中,key为代理的ip:port,value为一个计数,初始为1,每校验失败一次减1;
|
|
|
|
|
|
|
|
"""
|
|
"""
|
|
|
- # 为了保持DbClient的标准
|
|
|
|
|
- # 在SsdbClient里面接受username参数, 但不进行使用.
|
|
|
|
|
- # 因为不能将username通过kwargs传进redis.Redis里面, 会报错:
|
|
|
|
|
- # TypeError: __init__() got an unexpected keyword argument 'username'
|
|
|
|
|
- def __init__(self, name, username, **kwargs):
|
|
|
|
|
|
|
+ def __init__(self, name, **kwargs):
|
|
|
"""
|
|
"""
|
|
|
init
|
|
init
|
|
|
:param name: hash name
|
|
:param name: hash name
|
|
|
- :param host: ssdb host
|
|
|
|
|
- :param port: ssdb port
|
|
|
|
|
|
|
+ :param host: host
|
|
|
|
|
+ :param port: port
|
|
|
|
|
+ :param password: password
|
|
|
:return:
|
|
:return:
|
|
|
"""
|
|
"""
|
|
|
self.name = name
|
|
self.name = name
|
|
@@ -114,6 +111,7 @@ class SsdbClient(object):
|
|
|
def changeTable(self, name):
|
|
def changeTable(self, name):
|
|
|
self.name = name
|
|
self.name = name
|
|
|
|
|
|
|
|
|
|
+
|
|
|
if __name__ == '__main__':
|
|
if __name__ == '__main__':
|
|
|
- c = SsdbClient('useful_proxy', '118.24.52.95', 8899)
|
|
|
|
|
|
|
+ c = SsdbClient(name='useful_proxy', host='127.0.0.1', port=8899, password=None)
|
|
|
print(c.getAll())
|
|
print(c.getAll())
|