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

feat: 添加rn列到视频表以支持关键修复

Browse Source
This commit is contained in:
晓丰 2025-06-29 11:48:08 +08:00
parent b511dbc962
commit 42bc98b56e
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
DB.py
View File

@ -27,7 +27,6 @@ _engine = create_engine(
) )
_meta = MetaData() _meta = MetaData()
# 操作记录表 (sh_dm_video_op_v3)
video_op = Table("sh_dm_video_op_v3", _meta, video_op = Table("sh_dm_video_op_v3", _meta,
Column("id", Integer, primary_key=True, autoincrement=True), Column("id", Integer, primary_key=True, autoincrement=True),
Column("v_id", String(64)), Column("v_id", String(64)),
@ -49,11 +48,12 @@ video_op = Table("sh_dm_video_op_v3", _meta,
Column("ts_status", Integer, default=1), Column("ts_status", Integer, default=1),
) )
# 视频表 (sh_dm_video_v3) # 视频表
video = Table("sh_dm_video_v3", _meta, video = Table("sh_dm_video_v3", _meta,
Column("id", Integer, primary_key=True, autoincrement=True), Column("id", Integer, primary_key=True, autoincrement=True),
Column("v_id", String(64)), Column("v_id", String(64)),
Column("v_xid", String(64)), Column("v_xid", String(64)),
Column("rn", String(50)), # 关键修复：添加rn列
Column("v_name", String(255), nullable=False), Column("v_name", String(255), nullable=False),
Column("title", String(255), nullable=False), Column("title", String(255), nullable=False),
Column("link", String(255), nullable=False), Column("link", String(255), nullable=False),
@ -79,6 +79,7 @@ video = Table("sh_dm_video_v3", _meta,
Column("operatetime", Integer), Column("operatetime", Integer),
) )
# 作者表
video_author = Table( video_author = Table(
"sh_dm_video_author", "sh_dm_video_author",
_meta, _meta,
@ -95,6 +96,7 @@ video_author = Table(
Column("update_time", Integer, nullable=True, comment="更新时间（UNIX 时间戳）"), Column("update_time", Integer, nullable=True, comment="更新时间（UNIX 时间戳）"),
) )
def mysql_retry(max_retries: int = 3, base_delay: float = 2.0): def mysql_retry(max_retries: int = 3, base_delay: float = 2.0):
""" """
装饰器工厂：捕获 InterfaceError 后断线重连并重试， 装饰器工厂：捕获 InterfaceError 后断线重连并重试，