redis 单例模式 完成

livepocket/302_poc_2.py

@@ -212,7 +212,7 @@ def poc_2(account, passwd, target_url, log_name, single_proxy):
 
 def process_account(account, log_name, single_proxy):
     try:
-        run_poc(account.strip(), 'panyue666', 'https://t.livepocket.jp/e/sakuhana_197', log_name, single_proxy)
+        run_poc(account.strip(), 'panyue666', 'https://t.livepocket.jp/e/q8ucp', log_name, single_proxy)
     except Exception as ex:
         print(f'error: {traceback.format_exc()}, account:{account}')
 

config.yaml → tools/config.yaml

@@ -1,5 +1,6 @@
 redis:
   host: 'localhost'
   port: 6379
+  password: ''
   db: 0
   timeout: 600

tools/utils.py

@@ -9,6 +9,8 @@ import redis
 import requests
 import schedule
 
+from tools import redis_client
+
 
 # 随机生成token
 def get_token():
@@ -161,16 +163,14 @@ def save_proxy_ip(page, page_size):
                 proxy = f'{username}:{password}@{proxy_address_ip}:{port}'
 
                 # 连接Redis并存储代理IP
-                r = redis.Redis(host='localhost', port=6379, db=0)
-                r.set(f'proxy_{str(i)}', proxy)
+                redis_client.set(f'proxy_{str(i)}', proxy)
                 i = i + 1
 
 
 def get_random_proxy_at_redis(total):
     random_index = random.randint(0, total - 1)
     # 连接Redis并获取代理IP
-    r = redis.Redis(host='localhost', port=6379, db=0)
-    single_proxy = r.get(f'proxy_{str(random_index)}')
+    single_proxy = redis_client.get(f'proxy_{str(random_index)}')
 
     return single_proxy
 
@@ -227,4 +227,4 @@ if __name__ == "__main__":
     # file_writer = FileWriter('output.txt')
     # file_writer.write_to_file('Hello, World!')
     # 代理池存储到redis
-    save_proxy_ip(5, 30)
+    save_proxy_ip(1, 200)