awg ftp

data_processing/data_operation/data_nwp_ftp.py

@@ -86,7 +86,7 @@ def get_moment_next(schedule_dt=None):
     elif now.hour > 6:
         moment = '12'
     elif 2 >= now.hour >= 0:
-        moment = '00'
+        moment = '06'
     else:
         moment = '06'
     return date, moment

data_processing/data_operation/pre_prod_ftp.py

@@ -332,7 +332,7 @@ def configure_scheduler():
 
     # 配置第一个触发器：处理每个主小时段的前 60 分钟（0-50 分钟）
     trigger1 = CronTrigger(
-        hour='1,5,11,17',  # 主触发小时
+        hour='3,5,11,17',  # 主触发小时
         minute='0-50/10',  # 每 10 分钟一次，覆盖 00:00-00:50
         timezone='Asia/Shanghai'  # 按需设置时区
     )