调试

common/sql_help.py

@@ -1,5 +1,7 @@
 import os
 import sys
+from datetime import datetime
+
 sys.path.append(os.getcwd())
 from common.mysql_db import MysqlHelper
 
@@ -21,7 +23,9 @@ class sqlCollect():
 
     @classmethod
     def insert_pj_video_data(cls, user_video_id: str, channel: str):
-        insert_sql = f"""INSERT INTO pj_video_data (user_video_id,channel) values ("{user_video_id}", "{channel}")"""
+        current_time = datetime.now()
+        formatted_time = current_time.strftime("%Y-%m-%d %H:%M:%S")
+        insert_sql = f"""INSERT INTO pj_video_data (task_name, mark_name,user_video_id,channel,data_time) values ("{user_video_id}", "{channel}", "{user_video_id}", "{channel}", '{formatted_time}')"""
         MysqlHelper.update_values(
             sql=insert_sql
         )

job_top_data.py

@@ -77,6 +77,8 @@ def get_data_task():
                 Feishu.update_values("KUIksoqZkhvZOrtqA1McPwObn7d", "57c076", "A2:Z2", values)
                 logger.info(f"[+] 成功写入飞书表格")
                 logger.info(f"[+] 改内容为:{channel_id},不做处理")
+        else:
+            return top_tasks
 
     return top_tasks
 

top_automatic/top_data_processing.py

@@ -162,29 +162,6 @@ class Top:
         AliyunLogger.logging(data['channel'], data, "获取成功等待写入改造任务", channel_account_id)
         in_job_video_data(redis_data, json.dumps(data, ensure_ascii=False, indent=4))
         sqlCollect.insert_pj_video_data(channel_account_id, channel_id)
-        logger.info(f"[+] 开始写入飞书表格")
-        current_time = datetime.now()
-        formatted_time = current_time.strftime("%Y-%m-%d %H:%M:%S")
-        values = [
-            [
-                data['uid'],
-                data['videoid'],
-                data['return_uv'],
-                data['type'],
-                data['type_owner'],
-                data['channel'],
-                data['channel_owner'],
-                data['title'],
-                data['dt'],
-                channel_account_id,
-                tag_transport_channel,
-                formatted_time
-            ]
-        ]
-        Feishu.insert_columns("KUIksoqZkhvZOrtqA1McPwObn7d", "57c076", "ROWS", 1, 2)
-        time.sleep(0.5)
-        Feishu.update_values("KUIksoqZkhvZOrtqA1McPwObn7d", "57c076", "A2:Z2", values)
-        logger.info(f"[+] 成功写入飞书表格")
         return