|
@@ -24,50 +24,50 @@ def video_start(user_data):
|
|
|
Common.logger("video").info(f"返回用户名{mark}")
|
|
|
returned_usernames_today.append(user_data_mark)
|
|
|
|
|
|
-name_list = Material.feishu_list()
|
|
|
-video_start(name_list[2])
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-# def clear_returned_usernames():
|
|
|
-# returned_usernames_today.clear()
|
|
|
-# print("returned_usernames_today 已清空")
|
|
|
-#
|
|
|
-# # 定义定时任务
|
|
|
-# def video_task():
|
|
|
-# print("开始执行生成视频脚.")
|
|
|
-# data = Material.feishu_list()
|
|
|
-# # 创建一个线程池
|
|
|
-# with concurrent.futures.ThreadPoolExecutor() as executor:
|
|
|
-# futures = [executor.submit(video_start, user_data) for user_data in data]
|
|
|
-# # 等待所有任务执行完成
|
|
|
-# for future in concurrent.futures.as_completed(futures):
|
|
|
-# try:
|
|
|
-# # 获取每个任务的执行结果
|
|
|
-# result = future.result()
|
|
|
-# print("处理结果:", result)
|
|
|
-# except Exception as e:
|
|
|
-# print("处理任务时出现异常:", e)
|
|
|
-# print("执行生成视频脚结束")
|
|
|
-#
|
|
|
-#
|
|
|
-# # 每天0点10清空集合
|
|
|
-# schedule.every().day.at("00:10").do(clear_returned_usernames)
|
|
|
-#
|
|
|
-# #每10分钟执行次脚本
|
|
|
-# schedule.every(10).minutes.do(video_task)
|
|
|
-#
|
|
|
-#
|
|
|
-#
|
|
|
-#
|
|
|
-# # 每天下午1:30执行任务
|
|
|
-#
|
|
|
-# while True:
|
|
|
-# schedule.run_pending()
|
|
|
-# time.sleep(1)
|
|
|
-#
|
|
|
-# # list = Material.feishu_list()
|
|
|
-# # AgcVidoe.video_stitching(list)
|
|
|
-# # print(list)
|
|
|
-#
|
|
|
-#
|
|
|
+# name_list = Material.feishu_list()
|
|
|
+# video_start(name_list[1])
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+def clear_returned_usernames():
|
|
|
+ returned_usernames_today.clear()
|
|
|
+ print("returned_usernames_today 已清空")
|
|
|
+
|
|
|
+# 定义定时任务
|
|
|
+def video_task():
|
|
|
+ print("开始执行生成视频脚.")
|
|
|
+ data = Material.feishu_list()
|
|
|
+ # 创建一个线程池
|
|
|
+ with concurrent.futures.ThreadPoolExecutor() as executor:
|
|
|
+ futures = [executor.submit(video_start, user_data) for user_data in data]
|
|
|
+ # 等待所有任务执行完成
|
|
|
+ for future in concurrent.futures.as_completed(futures):
|
|
|
+ try:
|
|
|
+ # 获取每个任务的执行结果
|
|
|
+ result = future.result()
|
|
|
+ print("处理结果:", result)
|
|
|
+ except Exception as e:
|
|
|
+ print("处理任务时出现异常:", e)
|
|
|
+ print("执行生成视频脚结束")
|
|
|
+
|
|
|
+
|
|
|
+# 每天0点10清空集合
|
|
|
+schedule.every().day.at("00:10").do(clear_returned_usernames)
|
|
|
+
|
|
|
+#每10分钟执行次脚本
|
|
|
+schedule.every(10).minutes.do(video_task)
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+# 每天下午1:30执行任务
|
|
|
+
|
|
|
+while True:
|
|
|
+ schedule.run_pending()
|
|
|
+ time.sleep(1)
|
|
|
+
|
|
|
+# list = Material.feishu_list()
|
|
|
+# AgcVidoe.video_stitching(list)
|
|
|
+# print(list)
|
|
|
+
|
|
|
+
|