调试

data_channel/shipinhaodandian.py

@@ -9,27 +9,34 @@ class SPHDD:
         data_list = sqlCollect.get_shp_dd_data(url)
         list = []
         if data_list:
-            for data in data_list:
-                cover_url = data[4]
-                video_url = data[5]
-                if video_url and cover_url:
-                    video_id = data[0]
-                    old_title = data[1]
-                    # author_id = data[2]
-                    author_name = data[3]
-                    video_duration = data[6]
-                    from_user_id = data[7]
-                    from_user_name = data[8]
-                    from_group_id = data[9]
-                    from_group_name = data[10]
-                    source = data[11]
-                    wx_msg = data[12]
-                    log_data = f"user:{url},video_id:{video_id},video_url:{video_url},original_title:{old_title}"
-                    AliyunLogger.logging(f"{channel_id}-{source}", name, url, video_id, "扫描到一条视频", "2001", log_data)
-                    AliyunLogger.logging(f"{channel_id}-{source}", name, url, video_id, "符合规则等待改造", "2004", log_data)
-                    all_data = {"video_id": video_id, "cover": cover_url, "video_url": video_url, "rule": author_name,
-                                "old_title": old_title, "from_user_name": from_user_name, "from_group_name": from_group_name, "source": source, "wx_msg": wx_msg}
-                    list.append(all_data)
+            try:
+                for data in data_list:
+                    try:
+                        cover_url = data[4]
+                        video_url = data[5]
+                        if video_url and cover_url:
+                            video_id = data[0]
+                            old_title = data[1]
+                            # author_id = data[2]
+                            author_name = data[3]
+                            video_duration = data[6]
+                            from_user_id = data[7]
+                            from_user_name = data[8]
+                            from_group_id = data[9]
+                            from_group_name = data[10]
+                            source = data[11]
+                            wx_msg = data[12]
+                            log_data = f"user:{url},video_id:{video_id},video_url:{video_url},original_title:{old_title}"
+                            AliyunLogger.logging(f"{channel_id}-{source}", name, url, video_id, "扫描到一条视频", "2001", log_data)
+                            AliyunLogger.logging(f"{channel_id}-{source}", name, url, video_id, "符合规则等待改造", "2004", log_data)
+                            all_data = {"video_id": video_id, "cover": cover_url, "video_url": video_url, "rule": author_name,
+                                        "old_title": old_title, "from_user_name": from_user_name, "from_group_name": from_group_name, "source": source, "wx_msg": wx_msg}
+                            list.append(all_data)
+                    except:
+                        continue
+                    return list
+            except Exception:
+                return list
             return list
         return list