feat: 优化DB.py中的视频和操作记录的UPSERT逻辑,添加重复记录检查和日志记录
This commit is contained in:
parent
ab40a4ea3b
commit
ab2af1ab8f
7
DB.py
7
DB.py
@ -671,13 +671,6 @@ class DBVidcon:
|
|||||||
# 如果你存入的是 JSON 字符串,可以在这里做一次反序列化:
|
# 如果你存入的是 JSON 字符串,可以在这里做一次反序列化:
|
||||||
return json.loads(item) if item is not None else None
|
return json.loads(item) if item is not None else None
|
||||||
|
|
||||||
import time
|
|
||||||
import threading
|
|
||||||
import copy
|
|
||||||
from datetime import datetime
|
|
||||||
from sqlalchemy.dialects.mysql import insert as mysql_insert
|
|
||||||
from app import _engine, logger
|
|
||||||
from app.models import video, video_op, video_author
|
|
||||||
|
|
||||||
class DBSA:
|
class DBSA:
|
||||||
FLUSH_EVERY_ROWS = 100
|
FLUSH_EVERY_ROWS = 100
|
||||||
|
Loading…
x
Reference in New Issue
Block a user