启动脚本优化

agc_job.py

@@ -8,7 +8,7 @@ import threading
 from common import Material, Common, Feishu
 from video_agc.agc_video_method import AgcVidoe
 # 控制读写速度的参数
-MAX_BPS = 120 * 1024 * 1024  # 120MB/s
+MAX_BPS = 1 * 1024 * 1024  # 120MB/s
 MAX_WORKERS = os.cpu_count() * 2  # 线程池最大工作线程数量
 READ_WRITE_CHUNK_SIZE = 1024 * 1024  # 每次读写的块大小 (1MB)
 SLEEP_INTERVAL = READ_WRITE_CHUNK_SIZE / MAX_BPS  # 控制每次读写的延迟时间

data_assign_main.py

@@ -10,7 +10,7 @@ import threading
 import os
 
 # 控制读写速度的参数
-MAX_BPS = 120 * 1024 * 1024  # 120MB/s
+MAX_BPS = 10 * 1024 * 1024  # 120MB/s
 MAX_WORKERS = os.cpu_count() * 2  # 线程池最大工作线程数量
 READ_WRITE_CHUNK_SIZE = 1024 * 1024  # 每次读写的块大小 (1MB)
 SLEEP_INTERVAL = READ_WRITE_CHUNK_SIZE / MAX_BPS  # 控制每次读写的延迟时间

data_main.py

@@ -9,7 +9,7 @@ import threading
 import os
 
 # 控制读写速度的参数
-MAX_BPS = 120 * 1024 * 1024  # 120MB/s
+MAX_BPS = 10 * 1024 * 1024  # 120MB/s
 MAX_WORKERS = os.cpu_count() * 2  # 线程池最大工作线程数量
 READ_WRITE_CHUNK_SIZE = 1024 * 1024  # 每次读写的块大小 (1MB)
 SLEEP_INTERVAL = READ_WRITE_CHUNK_SIZE / MAX_BPS  # 控制每次读写的延迟时间
@@ -71,7 +71,6 @@ schedule.every(8).hours.do(douyin_task)
 
 schedule.every(8).hours.do(kuanshou_task)
 
-kuanshou_task()
 
 # 持续运行，直到手动终止
 while True: