zhangyong 8 月之前
父节点
当前提交
4e1d37ed67
共有 1 个文件被更改,包括 5 次插入9 次删除
  1. 5 9
      data_channel/sph_crawling_data.py

+ 5 - 9
data_channel/sph_crawling_data.py

@@ -98,7 +98,7 @@ class SphHistory:
                         if len(video_url) == 0:
                             continue
                         v_id = f"sph/{objectId}"
-                        Common.logger("sph_crawling").info(f"{user}视频ID:{v_id},视频链接:{video_url}开始发送oss")
+                        Common.logger("sph_crawling").info(f"{user}视频ID:{objectId},视频链接:{video_url}开始发送oss")
                         oss_video_key = Oss.channel_upload_oss(video_url, v_id)  # 视频发送OSS
                         oss_video_key = oss_video_key.get("oss_object_key")
                         Common.logger("sph_crawling").info(f"{user}视频发送oss成功,视频oss地址{oss_video_key}")
@@ -107,14 +107,10 @@ class SphHistory:
                         like_cnt = int(obj['like_count'])  # 点赞
                         video_title = video_obj.get('title').split("\n")[0].split("#")[0]
                         cover = video_obj.get('thumb_url')
-                        jpg_path = PQ.download_video_jpg(cover, video_path_url, v_id)  # 下载视频封面
-                        if os.path.isfile(jpg_path):
-                            oss_jpg_key = Oss.stitching_fm_upload_oss(jpg_path, v_id)  # 封面发送OSS
-                            oss_cover_key = oss_jpg_key.get("oss_object_key")
-                            Common.logger("sph_crawling").info(f"{user}封面发送oss成功,封面oss地址{oss_video_key}")
-                        else:
-                            oss_cover_key = ''
-                            Common.logger("sph_crawling").info(f"{user}封面发送oss失败")
+                        Common.logger("sph_crawling").info(f"{user}视频ID:{objectId},封面链接:{cover}开始发送oss")
+                        oss_cover_key = Oss.channel_upload_oss(cover, f"sph/{objectId}.jpg")  # 视频发送OSS
+                        oss_cover_key = oss_cover_key.get("oss_object_key")
+                        Common.logger("sph_crawling").info(f"{user}封面发送oss成功,封面oss地址{oss_video_key}")
                         create_time = obj['createtime']  # 发布时间
                         user_name = obj['username']  # 用户名标示
                         nick_name = obj['nickname']  # 用户名