Bladeren bron

redis 取值出现了bug

xubo 1 jaar geleden
bovenliggende
commit
9d5960cf24
2 gewijzigde bestanden met toevoegingen van 6 en 6 verwijderingen
  1. 5 5
      app.py
  2. 1 1
      tools/redis_util.py

+ 5 - 5
app.py

@@ -659,10 +659,10 @@ def process_running_manual(max_threads, pocket_url):
 
         threads = []
         for account in account_list:
-            # single_proxy = get_proxy_from_file("proxy_list.txt")
+            single_proxy = get_proxy_from_file("proxy_list.txt")
             # 从redis 中获取 proxy_ip
-            key = f'proxy_ip_{account}'
-            single_proxy = redis_client.get(key)
+            # key = f'proxy_ip_{account}'
+            # single_proxy = redis_client.get(key)
             print(f"当前账号: {account}, 当前代理:{single_proxy}")
             loggerKit.info(f"当前账号: {account}, 当前代理:{single_proxy}")
 
@@ -745,9 +745,9 @@ def run_threading_order(max_threads, account_path, url):
 
             threads = []
             for account in account_list:
-                # single_proxy = get_proxy_from_file("proxy_list.txt")
+                single_proxy = get_proxy_from_file("proxy_list.txt")
                 # 从redis 中获取 proxy_ip
-                single_proxy = redis_client.get(f'proxy_ip_{account}')
+                # single_proxy = redis_client.get(f'proxy_ip_{account}')
 
                 print(f"当前key: proxy_ip_{account}, 当前代理:{single_proxy}")
                 loggerKit.info(f"当前账号: {account}, 当前代理:{single_proxy}")

+ 1 - 1
tools/redis_util.py

@@ -13,7 +13,7 @@ class redis_util(object):
         self.__redis = redis_pool.redis_pool.get_conn()
 
     # 设置key-value
-    def set(self, key, value, timeout=24 * 60 * 60):
+    def set(self, key, value, timeout=1 * 60 * 60):
         self.__redis.set(key, value)
         # key超时时间
         self.__redis.expire(name=key, time=timeout)