调试

job_top_data.py

@@ -56,27 +56,26 @@ def get_data_task():
             else:
                 top_tasks.append(top_task)
                 AliyunLogger.logging(channel_id, data, "等待处理", "success")
-                values = [
-                    [
-                        data['uid'],
-                        data['videoid'],
-                        data['return_uv'],
-                        data['type'],
-                        data['type_owner'],
-                        data['channel'],
-                        data['channel_owner'],
-                        data['title'],
-                        data['dt'],
-                        "",
-                        "",
-                        formatted_time
-                    ]
-                ]
-                Feishu.insert_columns("KUIksoqZkhvZOrtqA1McPwObn7d", "57c076", "ROWS", 1, 2)
-                time.sleep(0.5)
-                Feishu.update_values("KUIksoqZkhvZOrtqA1McPwObn7d", "57c076", "A2:Z2", values)
+                # values = [
+                #     [
+                #         data['uid'],
+                #         data['videoid'],
+                #         data['return_uv'],
+                #         data['type'],
+                #         data['type_owner'],
+                #         data['channel'],
+                #         data['channel_owner'],
+                #         data['title'],
+                #         data['dt'],
+                #         "",
+                #         "",
+                #         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"[+] 成功写入飞书表格")
-                logger.info(f"[+] 改内容为:{channel_id},不做处理")
         else:
             return top_tasks
 

job_top_day_redis.py

@@ -15,7 +15,7 @@ def jab_day_recommend():
     """获取每日每小时top前100数据"""
     try:
         logger.info(f"开始获取溯源到的数据")
-        list_task = [{'task:top_data_ks_gjc': '77618314'}, {'task:top_data_dy_gjc':'77618313'}, {'task:top_data_ks_gz':'77618315'}, {'task:top_data_dy_gz':'77618316'}]
+        list_task = [{'task:top_data_ks_gjc': '77618314'}, {'task:top_data_dy_gjc':'77618313'}, {'task:top_data_ks_gz':'77618315'}, {'task:top_data_dy_gz':'77618317'}]
         for task in list_task:
             for key, value in task.items():
 

top_automatic/top_data_processing.py

@@ -162,6 +162,29 @@ 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