直播回放分片上传

live_replay_upload.py

@@ -21,7 +21,6 @@ def upload_to_oss(live_id, id):
         total_size = os.path.getsize(local_path)
         print(total_size)
         part_size = oss2.determine_part_size(total_size, preferred_size=1000 * 1024 * 1000)
-        PrintLog.print(live_id + ' 上传完成')
 
         # 初始化分片上传，得到Upload ID。接下来的接口都要用到这个Upload ID。
         upload_id = bucket.init_multipart_upload(oss_path).upload_id
@@ -47,7 +46,7 @@ def upload_to_oss(live_id, id):
         # 验证一下
         with open(local_path, 'rb') as file_obj:
             assert bucket.get_object(oss_path).read() == file_obj.read()
-
+        PrintLog.print(live_id + ' 上传完成')
         MysqlLiveReplay().set_task_status(id, '7')
         # 删除磁盘上的直播回放文件
         try: