Browse Source

恢复正常抓取

zhangyong 9 tháng trước cách đây
mục cha
commit
25b3e90580
1 tập tin đã thay đổi với 5 bổ sung5 xóa
  1. 5 5
      channel_ks/ks_feed_list.py

+ 5 - 5
channel_ks/ks_feed_list.py

@@ -274,20 +274,20 @@ class KsFeedVideo:
                                                   photo_id, category_name, age, oss_object=None, video_uid=None)
 
                         continue
-                    # oss_object_key = Oss.channel_upload_oss(main_mv_url, photo_id)
+                    oss_object_key = Oss.channel_upload_oss(main_mv_url, photo_id)
                     time.sleep(2)
-                    # oss_object = oss_object_key.get("oss_object_key")
+                    oss_object = oss_object_key.get("oss_object_key")
                     pq_id = cls.get_id_by_category(category_name)
                     if pq_id:
-                        # video_uid = cls.insert_piaoquantv(oss_object, caption, pq_id, thumbnail_url)
+                        video_uid = cls.insert_piaoquantv(oss_object, caption, pq_id, thumbnail_url)
                         sqlCollect.insert_ks_data(user_name, user_sex, time_data, caption, view_count,
                                                   like_count, share_count, duration, main_mv_url, thumbnail_url,
-                                                  user_id, '0', photo_id, category_name, age, oss_object=None, video_uid=None)
+                                                  user_id, '0', photo_id, category_name, age, oss_object, video_uid)
                         current_time = datetime.now()
                         formatted_time = current_time.strftime("%Y-%m-%d %H:%M:%S")
                         values = [
                             [category_name, user_name, photo_id, user_sex, caption, view_count, like_count, share_count, duration,
-                             main_mv_url, thumbnail_url, user_id, age, pq_id, "video_uid", time_data, formatted_time]]
+                             main_mv_url, thumbnail_url, user_id, age, pq_id, video_uid, time_data, formatted_time]]
                         Feishu.insert_columns("PlcisKhObhzmBothRutc65sJnph", "8fQxFv", "ROWS", 1, 2)
                         time.sleep(0.5)
                         Feishu.update_values("PlcisKhObhzmBothRutc65sJnph", "8fQxFv", "A2:Z2", values)