|
|
@@ -132,7 +132,6 @@ def download_files_via_sftp(mappings, datetime_str, local_temp_dir, model_type):
|
|
|
|
|
|
# 执行文件下载
|
|
|
for engineer in mappings:
|
|
|
- datetime_str = datetime_str if engineer == 'koi' else 2025012000
|
|
|
remote_base = f"/{engineer}/"
|
|
|
try:
|
|
|
sftp.chdir(remote_base)
|
|
|
@@ -210,7 +209,6 @@ def upload_to_sftp(local_path: str, target_dir: str) -> bool:
|
|
|
def process_zips(mappings, local_temp_dir, datetime_str, final_collect_dir):
|
|
|
"""处理所有下载的ZIP文件并收集场站目录"""
|
|
|
for engineer in mappings:
|
|
|
- datetime_str = datetime_str if engineer == 'koi' else 2025012000
|
|
|
for model_version in mappings[engineer]:
|
|
|
target_file = f"jy_{engineer}.{'.'.join(model_version)}_{datetime_str}_dq.zip"
|
|
|
zip_path = os.path.join(local_temp_dir, target_file).replace("\\", "/")
|
|
|
@@ -294,7 +292,6 @@ def prod_data_handler(mappings, model_type):
|
|
|
target_time = get_next_target_time()
|
|
|
datetime_str = target_time.strftime("%Y%m%d%H")
|
|
|
logger.info(f"目标时间: {datetime_str}")
|
|
|
- datetime_str = '2025012412'
|
|
|
|
|
|
# 下载文件
|
|
|
download_files_via_sftp(mappings, datetime_str, local_temp_dir, model_type)
|
David