|
|
@@ -258,14 +258,14 @@ def poc_2(account, passwd, target_url, log_name, single_proxy, random_index):
|
|
|
# writer.write_to_file(f'account:{account}, order_id:{order_id}, onetime_token_name:{onetime_token_name}, onetime_token_value:{onetime_token_value} \n')
|
|
|
|
|
|
|
|
|
-def process_account(account, log_name, single_proxy, random_index):
|
|
|
+def process_account(pocket_url, account, log_name, single_proxy, random_index):
|
|
|
try:
|
|
|
run_poc(account.strip(), 'panyue666', 'https://t.livepocket.jp/e/z230-', log_name, single_proxy, random_index)
|
|
|
except Exception as ex:
|
|
|
loggerKit.error(f'error: {traceback.format_exc()}, account:{account}')
|
|
|
|
|
|
|
|
|
-def process_running(max_threads):
|
|
|
+def process_running(max_threads, pocket_url):
|
|
|
log_name = f"data_{datetime.datetime.now().strftime('%Y%m%d%H%M')}.txt"
|
|
|
with open('account.txt', 'r') as accounts:
|
|
|
account_list = accounts.readlines()
|
|
|
@@ -275,7 +275,7 @@ def process_running(max_threads):
|
|
|
|
|
|
# 直接从redis中获取
|
|
|
single_proxy, random_index = get_random_proxy_at_redis(600)
|
|
|
- thread = threading.Thread(target=process_account, args=(account, log_name, single_proxy, random_index))
|
|
|
+ thread = threading.Thread(target=process_account, args=(pocket_url, account, log_name, single_proxy, random_index))
|
|
|
threads.append(thread)
|
|
|
thread.start()
|
|
|
|
|
|
@@ -317,7 +317,7 @@ def run_daily_job(hour, minute):
|
|
|
|
|
|
def looper_job():
|
|
|
while 1:
|
|
|
- process_running(max_threads=8)
|
|
|
+ process_running(max_threads=8, pocket_url='https://t.livepocket.jp/e/4zgef')
|
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
derrickx