kali/DailyMotion
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 格式化代码以提高可读性和一致性

Browse Source
This commit is contained in:
晓丰 2025-05-31 04:41:37 +08:00
parent 539ccad2f3
commit b160abf7cc
1 changed files with 20 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
onoe.py
View File

@ -1,7 +1,7 @@
import json import json
import random import random
import traceback import traceback
from urllib.parse import quote,urlparse from urllib.parse import quote, urlparse
import argparse import argparse
import time import time
import uuid import uuid
@ -18,7 +18,6 @@ from logger import logger
import os import os
import urllib3 import urllib3
db = DBVidcon() db = DBVidcon()
MACHINE_ID = None MACHINE_ID = None
MAX_WORKERS = 10 MAX_WORKERS = 10
@ -254,7 +253,7 @@ def solve_recaptcha_v3_with_proxy(
max_task_retries: int = 3, max_task_retries: int = 3,
polling_interval: float = 3, polling_interval: float = 3,
max_poll_attempts: int = 5 max_poll_attempts: int = 5
) -> str: ) -> str:
parsed = urlparse(proxy_str) parsed = urlparse(proxy_str)
proxy_kwargs = { proxy_kwargs = {
@ -424,7 +423,7 @@ def integrate_data_parallel():
while True: while True:
global proxiesdict global proxiesdict
proxiesdict = db.get_proxy_agent_dict() proxiesdict = db.get_proxy_agent_dict()
tasks, flag = db.item_keyword() tasks, flag = db.item_keyword(1)
if not tasks: if not tasks:
time.sleep(10) time.sleep(10)
continue continue
@ -463,13 +462,7 @@ def integrate_data_parallel():
"level": kitem["level"], "level": kitem["level"],
}) })
DBSA.flush() DBSA.flush()
if rollback[0]:
db.rollback_l0(rollback[0])
if rollback[1]:
db.rollback_l1(rollback[1])
if rollback[2]:
db.rollback_l2(rollback[2])
time.sleep(10)
def parse_args() -> argparse.Namespace: def parse_args() -> argparse.Namespace:
global MACHINE_ID, MAX_WORKERS global MACHINE_ID, MAX_WORKERS