调试

data_channel/piaoquan.py

@@ -270,17 +270,20 @@ class PQ:
     @classmethod
     def download_video(cls, video_url, video_path_url, video_id):
         video = video_path_url + str(video_id) + '.mp4'
-        for i in range(3):
-            payload = {}
-            headers = {}
-            response = requests.request("GET", video_url, headers=headers, data=payload)
-            if response.status_code == 200:
-                with open(f"{video}", "wb") as file:
-                    # 将响应内容写入文件
-                    file.write(response.content)
-                time.sleep(5)
-                return video
-        return video
+        try:
+            for i in range(3):
+                payload = {}
+                headers = {}
+                response = requests.request("GET", video_url, headers=headers, data=payload)
+                if response.status_code == 200:
+                    with open(f"{video}", "wb") as file:
+                        # 将响应内容写入文件
+                        file.write(response.content)
+                    time.sleep(5)
+                    return video
+            return video
+        except Exception:
+            return None
 
     """
     票圈站内视频下载
@@ -304,6 +307,6 @@ class PQ:
 
 
 if __name__ == '__main__':
-    url = "http://v4.oskwai.com/ksc1/T7qVBWEFBSjrv7NVhbGhsNl2ICHVGGGEMDBlOoVfF_FuzCc0vdIvcKD4UUp16kjTbXk6_ejDZCi4iRfHG6K4eS0-3pnDBwDwFWerXvRunw9xU0ByXTEGl-9Wzbj363zt_AkVvB9wKfX19ND6II5hXyXVeEDUewP-cPpM0Or2a4DGwY5BrANG4RSZPFv9aLai.mp4?pkey=AAXnIyRIVnnYu85CsuF4yaZdAorZod4I5c25wKyjobe3LKwhsazKOaz1bwyEDJEWPCNw4jcEvnVQuVNKhcVhxjLKwLw7LtUGqqHYHs2XgPZ69ROEDh29nxm2m5PY61nK1xk&tag=1-1724226171-sp-0-4h7q8yhfdr-65207c8678ea2e0b&type=hot&clientCacheKey=3xx7cw2mjene8gq_b.mp4&tt=b&di=279ad1bb&bp=10001"
+    url= 'http://111.51.148.73/ksc1/55LDHcm2DuGHbBbzIDfqMh-vfVhaCuIXZG0szwmCZj9pXLmq7otQhUyGXtBtc13Rb0C49a4FzRU5xfUaRQb6De46IO6hQBVqzjOkFArRDfTC7u9BThi0Bsa2w6PP_6dg7WQYKxU6ZIbYI2tnLfOXU5Ira-DEZuGDQbgpZstADnGtvLMkOiB6DImlhfgdxWIZ.mp4?tag=1-1724839019-sp-0-lgl7lhkrnt-8937a5c247b0f313&provider=self&ocid=341&clientCacheKey=3x3br4x5z5hew32_bF.mp4&tt=bF&di=6f31a709&bp=10001'
     a = PQ.download_video(url,'/Users/tzld/Desktop/video_rewriting/path','70100016')
     print(a)

job_dd_sph.py

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