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

feat: 移除DB.py中的冗余字段并优化视频记录字段保留逻辑

Browse Source
This commit is contained in:
晓丰 2025-07-01 19:39:27 +08:00
parent 3dcc9c39a4
commit 6d102f9e84
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
DB.py
View File

@ -759,10 +759,13 @@ class DBSA:
"follow_number": data.get("fans", 0), "follow_number": data.get("fans", 0),
"video_number": data.get("videos", 0), "video_number": data.get("videos", 0),
"is_repeat": 3, "is_repeat": 3,
# "is_piracy": data.get("is_piracy", 3),
"ts_status": data.get("ts_status", 1), "ts_status": data.get("ts_status", 1),
} }
# 仅保留 sh_dm_video_v3 表中存在的字段
video_fields = {c.name for c in video.columns}
vid_row = {k: v for k, v in vid_row.items() if k in video_fields}
cls._buf_op.append(op_row) cls._buf_op.append(op_row)
cls._buf_vid.append(vid_row) cls._buf_vid.append(vid_row)
cls._buf_payload.append(data) cls._buf_payload.append(data)
@ -854,7 +857,6 @@ class DBSA:
upd = { upd = {
"title": stmt.inserted.title, "title": stmt.inserted.title,
"link": stmt.inserted.link, "link": stmt.inserted.link,
# "is_piracy": stmt.inserted.is_piracy,
"edition": stmt.inserted.edition, "edition": stmt.inserted.edition,
"duration": stmt.inserted.duration, "duration": stmt.inserted.duration,
"watch_number": stmt.inserted.watch_number, "watch_number": stmt.inserted.watch_number,
@ -892,4 +894,4 @@ class DBSA:
if getattr(e.orig, "args", [None])[0] == 1213 and attempt < 2: if getattr(e.orig, "args", [None])[0] == 1213 and attempt < 2:
time.sleep(0.5 * (attempt + 1)) time.sleep(0.5 * (attempt + 1))
continue continue
raise raise