上线 ETL

搜索启动兜底
弃用票圈内视频

applications/routes.py

@@ -47,26 +47,26 @@ async def search_videos_from_the_web():
         function="search_videos_from_the_web",
         trace_id=trace_id
     )
-    # try:
-    kimi_info = await K.search_kimi_schedule(params=params)
-    video_id = await search_videos(
-        kimi_info=kimi_info,
-        trace_id=trace_id,
-        gh_id=gh_id
-    )
-    print(json.dumps(kimi_info, ensure_ascii=False, indent=4))
-    res = {
-        "trace_id": trace_id,
-        "code": 0,
-        "kimi_title": kimi_info['k_title'],
-        "search_video_id": video_id
-    }
-    # except Exception as e:
-    #     res = {
-    #         "trace_id": trace_id,
-    #         "code": 1,
-    #         "message": str(e)
-    #     }
+    try:
+        kimi_info = await K.search_kimi_schedule(params=params)
+        video_id = await search_videos(
+            kimi_info=kimi_info,
+            trace_id=trace_id,
+            gh_id=gh_id
+        )
+        print(json.dumps(kimi_info, ensure_ascii=False, indent=4))
+        res = {
+            "trace_id": trace_id,
+            "code": 0,
+            "kimi_title": kimi_info['k_title'],
+            "search_video_id": video_id
+        }
+    except Exception as e:
+        res = {
+            "trace_id": trace_id,
+            "code": 1,
+            "message": str(e)
+        }
     return jsonify(res)