|
|
@@ -31,7 +31,7 @@ def start_jobs():
|
|
|
scheduler = BackgroundScheduler()
|
|
|
scheduler.configure({'timezone': timezone("Asia/Shanghai")})
|
|
|
trigger1 = CronTrigger(
|
|
|
- hour='1,2,5,6,11,12,13,17,18', # 主触发小时
|
|
|
+ hour='0,1,2,4,5,6,11,12,13,16,17,18', # 主触发小时
|
|
|
minute='0-50/10', # 每 10 分钟一次，覆盖 00:00-00:50
|
|
|
timezone='Asia/Shanghai' # 按需设置时区
|
|
|
)
|
|
|
@@ -149,7 +149,7 @@ def download_zip_files_from_ftp(moment=None):
|
|
|
logger.info(f"Downloading {remote_file_path} to {local_file_path}")
|
|
|
ftp.retrbinary(f'RETR {remote_file_path}', local_file.write)
|
|
|
|
|
|
- logger.info(f"Downloaded {file_name}")
|
|
|
+ logger.info(f"时间：{now.strftime('%Y-%m-%d %H:%M:%S')}，下载了 {file_name} 文件")
|
|
|
zip_file_path.append(local_file_path)
|
|
|
# 解压 ZIP 文件到临时目录
|
|
|
for zip_file_p in zip_file_path:
|
David