|
|
@@ -659,7 +659,9 @@ 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
|
|
|
+ single_proxy = redis_client.get(f'proxy_ip_{account}')
|
|
|
print(f"当前账号: {account}, 当前代理:{single_proxy}")
|
|
|
loggerKit.info(f"当前账号: {account}, 当前代理:{single_proxy}")
|
|
|
|
|
|
@@ -690,7 +692,9 @@ def login_account(max_threads, accounts_path, 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
|
|
|
+ single_proxy = redis_client.get(f'proxy_ip_{account}')
|
|
|
print(f"当前账号: {account}, 当前代理:{single_proxy}")
|
|
|
loggerKit.info(f"当前账号: {account}, 当前代理:{single_proxy}")
|
|
|
|
|
|
@@ -742,7 +746,10 @@ 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}')
|
|
|
+
|
|
|
print(f"当前账号: {account}, 当前代理:{single_proxy}")
|
|
|
loggerKit.info(f"当前账号: {account}, 当前代理:{single_proxy}")
|
|
|
|