fix: 添加LIMIT限制以优化数据库查询并恢复异常处理
This commit is contained in:
parent
7ed3678811
commit
6260f8b69a
1
DB.py
1
DB.py
@ -321,6 +321,7 @@ class DBVidcon:
|
||||
sh_dm_fight_records
|
||||
WHERE
|
||||
status = 1
|
||||
LIMIT 10
|
||||
"""
|
||||
self.cursor.execute(sql)
|
||||
return self.cursor.fetchall()
|
||||
|
18
report.py
18
report.py
@ -12,12 +12,12 @@ while True:
|
||||
if len(lis) == 0:
|
||||
time.sleep(20)
|
||||
for li in lis:
|
||||
# try:
|
||||
logger.logger.info(f"name:{li['name_title']},link:{li['link']} ")
|
||||
info = d.process_ticket(li['name_title'], li['link'])
|
||||
logger.logger.info(f"info:{info}")
|
||||
db.update_fight_record_status(li['id'], 2, info)
|
||||
db.flush()
|
||||
# except Exception as e:
|
||||
# logger.logger.error(f"ID:{li['id']}, e:{e}")
|
||||
# db.update_fight_record_status(li['id'],3,str(e))
|
||||
try:
|
||||
logger.logger.info(f"name:{li['name_title']},link:{li['link']} ")
|
||||
info = d.process_ticket(li['name_title'], li['link'])
|
||||
logger.logger.info(f"info:{info}")
|
||||
db.update_fight_record_status(li['id'], 2, info)
|
||||
db.flush()
|
||||
except Exception as e:
|
||||
logger.logger.error(f"ID:{li['id']}, e:{e}")
|
||||
db.update_fight_record_status(li['id'],3,str(e))
|
||||
|
Loading…
x
Reference in New Issue
Block a user