feat: 添加调试信息以增强数据处理的可追踪性
This commit is contained in:
parent
82f134fe2f
commit
b1e54312ca
1
DB.py
1
DB.py
@ -220,6 +220,7 @@ class DBVidcon:
|
|||||||
|
|
||||||
@mysql_retry()
|
@mysql_retry()
|
||||||
def upsert_video(self, data: dict):
|
def upsert_video(self, data: dict):
|
||||||
|
print(fr"DB处理->{data.get('v_xid')}")
|
||||||
data.setdefault("a_id", 0)
|
data.setdefault("a_id", 0)
|
||||||
data.setdefault("history_status", "")
|
data.setdefault("history_status", "")
|
||||||
data.setdefault("is_piracy", 3)
|
data.setdefault("is_piracy", 3)
|
||||||
|
1
main.py
1
main.py
@ -650,6 +650,7 @@ def search_worker(payload, kitem, flag):
|
|||||||
if not v_list:
|
if not v_list:
|
||||||
for i in range(2):
|
for i in range(2):
|
||||||
time.sleep(i * 5)
|
time.sleep(i * 5)
|
||||||
|
print(f"处理->{kitem['keyword']}")
|
||||||
v_list = get_searchInfo(kitem['keyword'], kitem['level'], header, gproxies)
|
v_list = get_searchInfo(kitem['keyword'], kitem['level'], header, gproxies)
|
||||||
if v_list:
|
if v_list:
|
||||||
break
|
break
|
||||||
|
Loading…
x
Reference in New Issue
Block a user