更新脚本

workers/video_insight_trigger_work.py

@@ -148,7 +148,13 @@ class ConsumptionRecommend(object):
                 )"""
                 values.append(value)
                 # Combine SQL statement and values
-                sql += ",\n".join(values) + ";"
+                sql += ",\n".join(values) + """
+                ON DUPLICATE KEY UPDATE
+                    video_link = VALUES(video_link),
+                    video_title = VALUES(video_title),
+                    analysis_summary = VALUES(analysis_summary),
+                    analysis_timeline = VALUES(analysis_timeline)
+                ;"""
                 # Print SQL statement
                 # logger.info(f"{sql}")
                 MysqlHelper.update_values(sql)