derrickx 1 rok temu
rodzic
commit
236664075b
2 zmienionych plików z 4 dodań i 4 usunięć
  1. 1 1
      livepocket/302_full.py
  2. 3 3
      tools/utils.py

+ 1 - 1
livepocket/302_full.py

@@ -260,7 +260,7 @@ def poc_2(account, passwd, target_url, log_name, single_proxy, random_index):
 
 
 def process_account(account, log_name, single_proxy, random_index):
 def process_account(account, log_name, single_proxy, random_index):
     try:
     try:
-        run_poc(account.strip(), 'panyue666', 'https://t.livepocket.jp/e/9zsgs', log_name, single_proxy, random_index)
+        run_poc(account.strip(), 'panyue666', 'https://t.livepocket.jp/e/z230-', log_name, single_proxy, random_index)
     except Exception as ex:
     except Exception as ex:
         loggerKit.error(f'error: {traceback.format_exc()}, account:{account}')
         loggerKit.error(f'error: {traceback.format_exc()}, account:{account}')
 
 

+ 3 - 3
tools/utils.py

@@ -256,7 +256,7 @@ class FileWriter(metaclass=Singleton):
             print(f"An error occurred: {e}")
             print(f"An error occurred: {e}")
 
 
 
 
-def run_daily_task(hour, minute, page, page_size):
+def run_daily_task(hour, minute, page_size, total):
     # 获取当前日期和时间
     # 获取当前日期和时间
     now = datetime.datetime.now()
     now = datetime.datetime.now()
     # 计算下次运行时间
     # 计算下次运行时间
@@ -269,7 +269,7 @@ def run_daily_task(hour, minute, page, page_size):
     # 创建定时器对象
     # 创建定时器对象
     scheduler = sched.scheduler(time.time, time.sleep)
     scheduler = sched.scheduler(time.time, time.sleep)
     # 添加定时任务
     # 添加定时任务
-    scheduler.enter(wait_time, 1, save_proxy_ip, (page, page_size))
+    scheduler.enter(wait_time, 1, save_all_proxy_ip, (page_size, total))
     # 启动定时器
     # 启动定时器
     scheduler.run()
     scheduler.run()
 
 
@@ -306,7 +306,7 @@ if __name__ == "__main__":
     # 代理池存储到redis
     # 代理池存储到redis
     # save_proxy_ip(9, 100)
     # save_proxy_ip(9, 100)
     # 每天早上8点30开始执行
     # 每天早上8点30开始执行
-    # run_daily_task(8, 30, 1, 100)
+    run_daily_task(10, 30, 100, 9)
     # 打印本机网络出口IP
     # 打印本机网络出口IP
     # external_ip = get_external_ip()
     # external_ip = get_external_ip()
     # print(f"本机网络出口 IP 地址:", external_ip)
     # print(f"本机网络出口 IP 地址:", external_ip)