直播回放分片上传

live_replay_upload.py

@@ -46,12 +46,15 @@ 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:
+            MysqlLiveReplay().set_task_status(id, '7')
+            # 删除磁盘上的直播回放文件
             os.remove(local_path)
             PrintLog.print(live_id + ' 删除文件成功')
+
         except Exception as e:
             PrintLog.print('删除文件抛出异常：' + str(e))
     except Exception as e: