|
@@ -23,7 +23,7 @@ def str_to_list(arg):
|
|
|
|
|
|
def forecast_data_distribution(pre_data, args):
|
|
|
col_time = args['col_time']
|
|
|
- farm_id = args['farmId']
|
|
|
+ farm_id = args['farm_id']
|
|
|
dt = datetime.now(pytz.utc).astimezone(timezone("Asia/Shanghai")).strftime('%Y%m%d')
|
|
|
tomorrow = (datetime.now(pytz.utc).astimezone(timezone("Asia/Shanghai")) + timedelta(days=1)).strftime('%Y-%m-%d')
|
|
|
field_mapping = {'clearsky_ghi': 'clearskyGhi', 'dni_calcd': 'dniCalcd', 'surface_pressure': 'surfacePressure',
|