update

job.py

@@ -0,0 +1,23 @@
+from apscheduler.schedulers.blocking import BlockingScheduler
+from apscheduler.triggers.interval import IntervalTrigger
+from loguru import logger
+from workers.consumption_work import ConsumptionRecommend
+
+
+def run():
+    scheduler = BlockingScheduler()
+    try:
+        logger.info(f"[长文] 开始启动")
+        scheduler.add_job(ConsumptionRecommend.run, trigger=IntervalTrigger(minutes=1))  # 每1分钟启动一次
+        scheduler.start()
+    except KeyboardInterrupt:
+        pass
+    except Exception as e:
+        logger.error(f"[长文] 启动异常，异常信息:{e}")
+        pass
+    finally:
+        scheduler.shutdown()
+
+
+if __name__ == '__main__':
+    run()

workers/consumption_work.py

@@ -8,7 +8,7 @@ from loguru import logger
 from utils.gpt4o_mini_help import GPT4oMini
 from utils.tts_help import TTS
 
-sys.path.append('/app')
+# sys.path.append('/app')
 from utils.download_video import DownLoad
 from utils.sql_help import sqlCollect
 from utils.aliyun_oss import Oss
@@ -22,6 +22,7 @@ from utils.ffmpeg import FFmpeg
 
 # CACHE_DIR = '/app/cache/'
 CACHE_DIR = '/Users/z/Downloads/'
+CACHE_DIR = '/root/long_text_video_transform/path/'
 class ConsumptionRecommend(object):
 
 
@@ -135,21 +136,21 @@ class ConsumptionRecommend(object):
             return
 
 
-
-def run():
-    scheduler = BlockingScheduler()
-    try:
-        logger.info(f"[长文] 开始启动")
-        scheduler.add_job(ConsumptionRecommend.run, trigger=IntervalTrigger(minutes=1))  # 每1分钟启动一次
-        scheduler.start()
-    except KeyboardInterrupt:
-        pass
-    except Exception as e:
-        logger.error(f"[长文] 启动异常，异常信息:{e}")
-        pass
-    finally:
-        scheduler.shutdown()
-
-
-if __name__ == '__main__':
-    ConsumptionRecommend.run()
+#
+# def run():
+#     scheduler = BlockingScheduler()
+#     try:
+#         logger.info(f"[长文] 开始启动")
+#         scheduler.add_job(ConsumptionRecommend.run, trigger=IntervalTrigger(minutes=1))  # 每1分钟启动一次
+#         scheduler.start()
+#     except KeyboardInterrupt:
+#         pass
+#     except Exception as e:
+#         logger.error(f"[长文] 启动异常，异常信息:{e}")
+#         pass
+#     finally:
+#         scheduler.shutdown()
+#
+#
+# if __name__ == '__main__':
+#     ConsumptionRecommend.run()