定时任务时间

utils/google_ai_analyze.py

@@ -155,7 +155,7 @@ class GoogleAI(object):
             prompts = load_prompts()
             analysis_data = {}
             for prompt in prompts[:3]:
-                print(f"[分析] 正在执行: {prompt['name']}")
+                # print(f"[分析] 正在执行: {prompt['name']}")
                 try:
                     result = cls._analyze_content(video, prompt['content'])
                     # 提取 result 中的 "内容分段" 和 "视频简介"
@@ -172,11 +172,11 @@ class GoogleAI(object):
                         "error": str(e),
                         "error_type": type(e).__name__
                     }
-            print(f"[分析] 所有分析完成, 结果: {analysis_data}")
+            # print(f"[分析] 所有分析完成, 结果: {analysis_data}")
 
             coze_hook = CozeHook()
             demand_list = coze_hook.run(analysis_data["视频选题与要点理解"], analysis_data["视频分段与时间点分析"])
-            print(f"[分析] 所有分析完成, 结果: {demand_list}")
+            # print(f"[分析] 所有分析完成, 结果: {demand_list}")
 
             genai.delete_file(name=video.name)
             os.remove(video_path)

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 300'
+        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 600'
         data = OdpsDataCount.main(sql)
         if not data:
             return
@@ -31,7 +31,7 @@ def requirement_insight():
         logger.error(f"[R] 写入Redis写入失败，失败信息{e}")
 
 def schedule_tasks():
-    schedule.every().day.at("01:00").do(requirement_insight)
+    schedule.every().day.at("15:15").do(requirement_insight)
 
 
 if __name__ == "__main__":

workers/video_insight_trigger_work.py

@@ -150,9 +150,9 @@ class ConsumptionRecommend(object):
                 # Combine SQL statement and values
                 sql += ",\n".join(values) + ";"
                 # Print SQL statement
-                logger.info(f"{sql}")
+                # logger.info(f"{sql}")
                 MysqlHelper.update_values(sql)
-                logger.info(f"[处理 - trigger] 视频分析结果写入数据库成功")
+                # logger.info(f"[处理 - trigger] 视频分析结果写入数据库成功")
                 
             except Exception as e:
                 logger.error(f"[处理 - trigger] 写入视频分析结果时出错: {e}")