|
@@ -98,8 +98,11 @@ class SphHistory:
|
|
if len(video_url) == 0:
|
|
if len(video_url) == 0:
|
|
continue
|
|
continue
|
|
v_id = f"sph/{objectId}"
|
|
v_id = f"sph/{objectId}"
|
|
|
|
+ Common.logger("sph_crawling").info(f"{user}视频{video_url}发送oss")
|
|
oss_video_key = Oss.channel_upload_oss(video_url, v_id) # 视频发送OSS
|
|
oss_video_key = Oss.channel_upload_oss(video_url, v_id) # 视频发送OSS
|
|
oss_video_key = oss_video_key.get("oss_object_key")
|
|
oss_video_key = oss_video_key.get("oss_object_key")
|
|
|
|
+ Common.logger("sph_crawling").info(f"{user}视频发送oss成功,视频oss地址{oss_video_key}")
|
|
|
|
+
|
|
share_cnt = int(obj['forward_count']) # 分享
|
|
share_cnt = int(obj['forward_count']) # 分享
|
|
like_cnt = int(obj['like_count']) # 点赞
|
|
like_cnt = int(obj['like_count']) # 点赞
|
|
video_title = video_obj.get('title').split("\n")[0].split("#")[0]
|
|
video_title = video_obj.get('title').split("\n")[0].split("#")[0]
|
|
@@ -108,9 +111,10 @@ class SphHistory:
|
|
if os.path.isfile(jpg_path):
|
|
if os.path.isfile(jpg_path):
|
|
oss_jpg_key = Oss.stitching_fm_upload_oss(jpg_path, v_id) # 封面发送OSS
|
|
oss_jpg_key = Oss.stitching_fm_upload_oss(jpg_path, v_id) # 封面发送OSS
|
|
oss_cover_key = oss_jpg_key.get("oss_object_key")
|
|
oss_cover_key = oss_jpg_key.get("oss_object_key")
|
|
|
|
+ Common.logger("sph_crawling").info(f"{user}封面发送oss成功,封面oss地址{oss_video_key}")
|
|
else:
|
|
else:
|
|
oss_cover_key = ''
|
|
oss_cover_key = ''
|
|
- Common.logger("sph_crawling").info(f"{user}oss地址:视频{oss_video_key},封面{oss_cover_key}")
|
|
|
|
|
|
+ Common.logger("sph_crawling").info(f"{user}封面发送oss失败")
|
|
create_time = obj['createtime'] # 发布时间
|
|
create_time = obj['createtime'] # 发布时间
|
|
user_name = obj['username'] # 用户名标示
|
|
user_name = obj['username'] # 用户名标示
|
|
nick_name = obj['nickname'] # 用户名
|
|
nick_name = obj['nickname'] # 用户名
|