调试

data_channel/ks_xcx.py

@@ -45,7 +45,7 @@ class KSXCX:
                     view_count = data.get('viewCount', 0)
                     title = data['caption']
                     photo_id = data['photoId']
-                    user_name = data['userName']
+                    user_name = data['share_info']
                     log_data = f"user:快手小程序,,video_id:{photo_id},,video_url:{video_url},original_title:{title},,share_count:{share_count},,view_count:{view_count},,duration:{duration}"
                     AliyunLogger.logging("快手小程序",  "快手小程序",user_name, photo_id, "扫描到一条视频", "2001", log_data)
                     status = sqlCollect.ks_is_used_xcx(photo_id,"快手小程序")

job_ks_xcx.py

@@ -11,7 +11,7 @@ def video_task_start():
             print("开始执行任务")
             mark = VideoProcessor.main(data)
             print(f"返回用户名: {mark}")
-            time.sleep(120 if mark else 120)  # 根据 mark 是否为空设置延迟
+            time.sleep(60 if mark else 60)  # 根据 mark 是否为空设置延迟
         except Exception as e:
             print("处理任务时出现异常:", e)
             time.sleep(10)