修改 MySQL 为线上服务

applications/routes.py

@@ -54,7 +54,7 @@ def Routes(mysql_client):
             trace_id=trace_id
         )
         insert_sql = f"""
-            INSERT INTO long_articles_video_dev 
+            INSERT INTO long_articles_video 
                 (trace_id, gh_id, article_title, article_text, account_name)
             VALUES 
                 ('{trace_id}', '{gh_id}', '{title}', '{contents}', '{account_name}');"""
@@ -66,7 +66,7 @@ def Routes(mysql_client):
             content_title = kimi_info['content_title']
             content_keys = json.dumps(kimi_info['content_keys'], ensure_ascii=False)
             update_kimi_sql = f"""
-                UPDATE long_articles_video_dev SET
+                UPDATE long_articles_video SET
                 kimi_title = '{kimi_title}',
                 kimi_summary = '{content_title}',
                 kimi_keys = '{content_keys}'

applications/schedule/process_schedule.py

@@ -17,7 +17,7 @@ async def recall_videos(trace_id, mysql_client):
     """
     select_sql = f"""
         SELECT recall_video_id1, kimi_title 
-        FROM long_articles_video_dev
+        FROM long_articles_video
         WHERE trace_id = '{trace_id}';
     """
     info_tuple = await mysql_client.async_select(select_sql)
@@ -59,7 +59,7 @@ async def recall_videos(trace_id, mysql_client):
             "videoUrl": videoUrl
         }
         update_result_sql = f"""
-            UPDATE long_articles_video_dev
+            UPDATE long_articles_video
             SET
                 result1 = '{json.dumps(result, ensure_ascii=False)}',
                 success = 1

applications/schedule/search_schedule.py

@@ -243,7 +243,7 @@ async def search_videos(kimi_info, trace_id, gh_id, mysql_client):
                 platform=platform,
             )
             update_id_sql = f"""
-            UPDATE long_articles_video_dev
+            UPDATE long_articles_video
             SET
             recall_video_id1 = {video_id}
             WHERE