增加异常处理

job_redis_data.py

@@ -7,21 +7,26 @@ from common.redis import install_video_data
 
 def bot_video_ai_top():
     """当日头部"""
-    dt = datetime.datetime.now().strftime('%Y%m%d')
-    print(f"开始执行头部{dt}")
-    redis_task = 'task:video_ai_top'
-    table_name = 'content_ai_tag_return_top_merge'
-    install_video_data(dt, redis_task, table_name)
-
+    try:
+        dt = datetime.datetime.now().strftime('%Y%m%d')
+        print(f"开始执行头部{dt}")
+        redis_task = 'task:video_ai_top'
+        table_name = 'content_ai_tag_return_top_merge'
+        install_video_data(dt, redis_task, table_name)
+    except Exception as e:
+        print(f"当日头部异常了{e}")
 
 
 def bot_video_ai_recommend():
     """新推荐"""
-    dt = datetime.datetime.now().strftime('%Y%m%d%H')
-    print(f"开始执行新推荐{dt}")
-    redis_task = 'task:video_ai_recommend'
-    table_name = 'content_ai_tag_recommend'
-    install_video_data(dt, redis_task, table_name)
+    try:
+        dt = datetime.datetime.now().strftime('%Y%m%d%H')
+        print(f"开始执行新推荐{dt}")
+        redis_task = 'task:video_ai_recommend'
+        table_name = 'content_ai_tag_recommend'
+        install_video_data(dt, redis_task, table_name)
+    except Exception as e:
+        print(f"新推荐异常了{e}")