直播回放上传至OSS

live_replay_upload.py

@@ -19,11 +19,11 @@ def upload_to_oss(live_id):
         PrintLog.print(live_id + ' 上传完成')
 
         # 删除磁盘上的直播回放文件
-        try:
-            os.remove(local_path)
-            PrintLog.print(live_id + ' 删除文件成功')
-        except Exception as e:
-            PrintLog.print('删除文件抛出异常：' + str(e))
+        # try:
+        #     os.remove(local_path)
+        #     PrintLog.print(live_id + ' 删除文件成功')
+        # except Exception as e:
+        #     PrintLog.print('删除文件抛出异常：' + str(e))
     except Exception as e:
         PrintLog.print('上传文件抛出异常：' + str(e))
         raise e

show_video_upload.py

@@ -1,89 +0,0 @@
-#!/usr/bin/python3
-# coding=utf-8
-# -*- coding: utf-8 -*-
-
-import os
-import time
-import sys
-from libs.mysql_kwai_show_video import MysqlKwaiShowVideo
-from libs.ali_oss import AliOss
-from log.print_log import PrintLog
-
-
-def upload_to_oss(live_id):
-    try:
-        file_name = live_id + '.flv'
-
-        local_path = sys.path[0] + '/file/' + file_name
-        oss_path = 'live_video/' + file_name
-
-        PrintLog.print(live_id + ' 开始上传')
-        bucket = AliOss.get_auth_bucket()
-        bucket.put_object_from_file(oss_path, local_path, progress_callback=percentage)
-        PrintLog.print(live_id + ' 上传完成')
-
-        try:
-            os.remove(local_path)
-            PrintLog.print(live_id + ' 删除文件成功')
-        except Exception as e:
-            PrintLog.print('删除文件抛出异常：' + str(e))
-
-    except Exception as e:
-        PrintLog.print('上传文件抛出异常：' + str(e))
-        raise e
-        pass
-
-
-# 当无法确定待上传的数据长度时，total_bytes的值为None。
-def percentage(consumed_bytes, total_bytes):
-    global start_time
-    current_time = time.time()
-    current_consumed_m_bytes = round(consumed_bytes / 1024 / 1024, 2)
-    rate = int(100 * (float(consumed_bytes) / float(total_bytes)))
-    diff_time = round(current_time - start_time)
-
-    if total_bytes:
-        print('\r{0}% '.format(rate), end='')
-        sys.stdout.flush()
-    if diff_time > 60:
-        start_time = current_time
-        PrintLog.print('\r已上传' + str(current_consumed_m_bytes) + 'M (' + str(rate) + '%)')
-
-
-def upload_live_video():
-
-    PrintLog.print('获取需要上传的直播')
-
-    video_info = MysqlKwaiShowVideo().get_downloaded_video()
-
-    if video_info is None:
-        time.sleep(60)
-        return
-
-    id, live_id = video_info
-    upload_to_oss(live_id)
-
-    try:
-        url = AliOss.BaseUrl + live_id + '.flv'
-        MysqlKwaiShowVideo().set_video_url(id, url)
-        PrintLog.print(live_id + ' 更新数据表成功')
-    except Exception as e:
-        PrintLog.print('更新数据表抛出异常：' + str(e))
-        time.sleep(1)
-
-
-if __name__ == "__main__":
-    while True:
-        try:
-            hour = int(time.strftime("%H", time.localtime()))
-            if hour > 17:
-                PrintLog.print('当前时间段不进行上传操作')
-                time.sleep(3600)
-                continue
-
-            start_time = time.time()
-            upload_live_video()
-        except Exception as e:
-            PrintLog.print('抛出异常：' + str(e))
-            time.sleep(1)
-            continue