调试

carry_data_handle.py

@@ -13,7 +13,9 @@ ENV = os.getenv('ENV', 'dev')
 NAME = os.getenv('NAME')
 REDIS_NAME = os.getenv('REDIS_NAME')
 CACHE_DIR = '/app/cache/' if ENV == 'prod' else os.path.expanduser('~/Downloads/')
+
 def video_task_start():
+    logger.info(f"[+] {REDIS_NAME}任务开始redis获取")
     data = get_carry_data(REDIS_NAME)
     if not data:
         return
@@ -47,5 +49,4 @@ if __name__ == '__main__':
     while True:
         schedule.run_pending()
         time.sleep(1)  # 每秒钟检查一次
-
     # video_task_start()

carry_video/carry_video.py

@@ -112,14 +112,15 @@ class CarryViode:
             url = pattern.group()
         host = urlparse(url).netloc
         if host in ['v.douyin.com', 'www.douyin.com', 'www.iesdouyin.com']:
+            logger.info(f"[+] {url}开始获取抖音视频链接")
             url, original_title =  self.get_text_dy_video(url=url)
         elif host in ['v.kuaishou.com', 'www.kuaishou.com', 'v.m.chenzhongtech.com', 'creater.eozatvmq.com']:
+            logger.info(f"[+] {url}开始获取快手视频链接")
             url, original_title = self.get_text_ks_video(url=url)
         else:
             logger.error(f"[+] {url}该链接不是抖/快 不做处理")
             AliyunLogger.logging(data["name"], "效率工具",data["tag_transport_channel"], data["video_url"],
                                  "不是抖/快不做处理", "1001", str(data))
-
             return
         if not url:
             in_carry_video_data(REDIS_NAME, data)
@@ -127,10 +128,12 @@ class CarryViode:
             AliyunLogger.logging(data["name"], "效率工具",data["tag_transport_channel"], data["video_url"],
                                  "没有获取到视频链接，等待重新处理", "1002", str(data))
             return
+        logger.info(f"[+] {url}开始处理标题")
         if data["title_category"] == "AI标题" or data["trailer_share"] == "AI标题":
             title = GPT4o.get_ai_title(original_title if data["title_category"] == "原标题" else data["title_category"])
         else:
             title = original_title if data["title_category"] == "原标题" else data["title_category"]
+        logger.info(f"[+] {url}开始下载视频")
         video_path = DownLoad.download_video(url, file_path)
         # video_path = Oss.download_video_oss(url, file_path)
         if not video_path:
@@ -139,6 +142,7 @@ class CarryViode:
                                  "视频下载失败", "3002", str(data))
             print("飞书通知")
             return
+        logger.info(f"[+] {url}开始视频下载成功")
         if data["transform_rule"] == '否':
             logger.info(f"[+] {REDIS_NAME}的{data}数据开始发送oss")
             oss_object_key = Oss.stitching_sync_upload_oss(video_path, str(uuid.uuid4()))  # 视频发送OSS

common/tts_help.py

@@ -149,7 +149,7 @@ class TTS:
 
     @classmethod
     def getSrt(cls, mp3_id):
-        url = "http://api-internal.piaoquantv.com/produce-center/srt/get/content"
+        url = "http://api.piaoquantv.com/produce-center/srt/get/content"
 
         payload = json.dumps({
             "params": {