八成是丟失連接了
while 1:
try:
self.conn.ping(reconnect=True)
self.cur.execute(sql,tuple(item.values()))
self.conn.commit()
break
except Exception as e:
print("error save item ",e)
self.r.lpush("save_article_error",str(item))
time.sleep(5)
self.get_redisconn()
在每次執行sql語句前先執行 conn.ping(reconnect=True),可以保證conn丟失時自動重連。