|
|
@@ -108,7 +108,7 @@ def get_nwp_from_ftp():
|
|
|
logger.info(args)
|
|
|
df = get_data_from_mongo(args)
|
|
|
df['date_time'] = pd.to_datetime(df['date_time'])
|
|
|
- df = df.sort_values(by='date_time')
|
|
|
+ df = df.sort_values(by='date_time')[['farm_id', 'date_time', 'power_forecast']]
|
|
|
# 2. 将预测结果保存成csv临时文件，命名压缩
|
|
|
zip_path, zip_file = zip_temp_file(df, args)
|
|
|
# 3. 上传到指定的FTP服务器中
|
