Merge branch 'feature_Trigger2' of Server/video-insight into master

product.env

@@ -3,5 +3,5 @@ VIDEO_INSIGHT_GEMINI_API_KEY_1=AIzaSyAHt9h0ScYki7NmgOXa1jj-UEimCa6JEOs
 VIDEO_INSIGHT_GEMINI_API_KEY_2=AIzaSyDH2uytot4wMwqvnCr0DKMb0Cs28tMfZS8
 VIDEO_INSIGHT_GEMINI_API_KEY_3=AIzaSyACAYPZH1pzAhgTjHjhw4thQ2hLr3bGf-w
 VIDEO_INSIGHT_GEMINI_API_KEY_4=AIzaSyCzm3Mgtv7c3Z_8MUVgMMNCDLk6vuoKtpU
-VIDEO_INSIGHT_GEMINI_API_KEY_5=AIzaSyDDEkSqzpP8VltmzgRuhHPuClBhDnMMxg8
-VIDEO_INSIGHT_GEMINI_API_KEY_6=AIzaSyCMB_7fLEOSZgi0pAFPzZ6E5J91IaL2SPQ
+VIDEO_INSIGHT_GEMINI_API_KEY_5=AIzaSyCBMiu12HVkjMZBsC7SOUqwbK1Dme6_igQ
+VIDEO_INSIGHT_GEMINI_API_KEY_6=AIzaSyBziAREIdTRtOZCp4KmNUjNpNDpbysgY-s

utils/google_ai_analyze.py

@@ -291,7 +291,7 @@ class GoogleAI(object):
 
 if __name__ == '__main__':
     ai = GoogleAI()
-    ai.run("AIzaSyACAYPZH1pzAhgTjHjhw4thQ2hLr3bGf-w",
+    ai.run("AIzaSyBziAREIdTRtOZCp4KmNUjNpNDpbysgY-s",
                  "http://rescdn.yishihui.com/jq_oss/video/2025012215472528213")
     # ai._analyze_content_with_api("http://rescdn.yishihui.com/longvideo/crawler_local/video/prod/20241206/5f98b0e4464d02d6c75907302793902d12277")
 

workers/video_insight_select_work.py

@@ -20,7 +20,7 @@ def requirement_insight():
         logger.info(f"视频需求点洞察")
         # redis_task = "task:video_insight"
         redis_trigger_task = "task:video_trigger_insight"
-        sql =f'select clickobjectid as video_id from loghubods.user_share_log where dt = {dt} and topic = "click" group by clickobjectid order by count(distinct machinecode) desc limit 900'
+        sql =f'select clickobjectid as video_id from loghubods.user_share_log where dt = {dt} and topic = "click" group by clickobjectid order by count(distinct machinecode) desc limit 1200'
         data = OdpsDataCount.main(sql)
         if not data:
             return

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)
@@ -169,7 +175,7 @@ async def run():
     scheduler = AsyncIOScheduler()
     try:
         logger.info(f"[处理 - trigger] 开始启动")
-        scheduler.add_job(ConsumptionRecommend.run, trigger=IntervalTrigger(minutes=7))  # 每5分钟启动一次
+        scheduler.add_job(ConsumptionRecommend.run, trigger=IntervalTrigger(minutes=5))  # 每5分钟启动一次
         scheduler.start()
         await asyncio.Event().wait()
     except KeyboardInterrupt: