。。

utils/google_ai_analyze.py

@@ -223,7 +223,7 @@ class GoogleAI(object):
             )
             response.raise_for_status()
             result = response.json()
-            logger.info(f"[内容分析] API原始响应: {result}")
+            # print(f"[内容分析] API原始响应: {result}")
             
             if not result:
                 raise Exception("API返回结果为空")
@@ -270,7 +270,7 @@ class GoogleAI(object):
                 if not demand_list:
                     raise Exception("CozeHook处理结果为空")
                     
-                logger.info(f"[内容分析] API分析完成, 结果: {analysis_data}, {demand_list}")
+                # print(f"[内容分析] API分析完成, 结果: {analysis_data}, {demand_list}")
                 return analysis_data, demand_list
                 
             except orjson.JSONDecodeError as e:

workers/video_insight_select_work.py

@@ -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("16:00").do(requirement_insight)
 
 
 if __name__ == "__main__":

workers/video_insight_trigger_work.py

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