The DataManager class

class data_manager.DataManager(influxdb_client, cfg, logger, influx_df_client=None)

Bases: object

Generic interface for data (measures and forecasts) management

static aggregate_dataframes(inputs, func)

static apply_function_to_forecast(func, i1, i2)

static apply_function_to_measures(func, i1, i2)

archive_file(file_name)

calc_aggregated_data_for_given_period(from_str, to_str)

calc_artificial_data_for_given_period(from_str, to_str)

calc_kpis()

calculate_artificial_data()

static check_folder(folder)

close_ftp_connection()

create_aggregated_data()

delete_remote_files()

static digitalize_output(output, pars)

download_remote_files()

get_forecast_data(loc, sig, st_date, end_date)

static get_loc_sig(locations, signals, func)

get_measure_data(loc, sig, st_date, end_date)

get_single_signals(fr)

get_start_end_dates()

handle_measures_file(file_path, file_name, dps)

handle_meteo_forecasts_file(input_file, dps)

Save measures data (OASI and ARPA) in InfluxDB

Parameters

input_file (string) – input file

insert_data()

static is_float(s)

is_meteosuisse_forecast_file(file_name)

static mean_absolute_percentage_error(y_true, y_pred)

open_ftp_connection()

point_handling(dps, point)

Add a point and (eventually) store the entire dataset in InfluxDB

Parameters

• point (dict) – point to add

• dps (list) – input data points

Returns

output data points

Return type

list

update_training_datasets(new_value, location)

Update the output training dataset :param new_value: new output value :type new_value: float :param location: location related to the new value :type location: string

upload_file(file_to_send)

data_manager.warn(*args, **kwargs)