|
@@ -17,7 +17,7 @@ CACHE_DIR = '/app/cache/' if ENV == 'prod' else os.path.expanduser('~/Downloads/
|
|
|
|
|
|
|
|
def video_task_start():
|
|
def video_task_start():
|
|
|
logger.info(f"[+] {REDIS_NAME}任务开始redis获取")
|
|
logger.info(f"[+] {REDIS_NAME}任务开始redis获取")
|
|
|
- while True:
|
|
|
|
|
|
|
+ for i in range(20):
|
|
|
data = get_carry_data(REDIS_NAME)
|
|
data = get_carry_data(REDIS_NAME)
|
|
|
if not data:
|
|
if not data:
|
|
|
return
|
|
return
|
|
@@ -46,8 +46,8 @@ def schedule_tasks():
|
|
|
schedule.every(6).minutes.do(video_task_start)
|
|
schedule.every(6).minutes.do(video_task_start)
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
if __name__ == '__main__':
|
|
|
|
|
+ video_task_start()
|
|
|
schedule_tasks() # 调用任务调度函数
|
|
schedule_tasks() # 调用任务调度函数
|
|
|
while True:
|
|
while True:
|
|
|
schedule.run_pending()
|
|
schedule.run_pending()
|
|
|
time.sleep(1) # 每秒钟检查一次
|
|
time.sleep(1) # 每秒钟检查一次
|
|
|
- # video_task_start()
|
|
|
