LoadsWaterwebservicesRWS

loads.LoadsWaterwebservicesRWS()

Belastinggegevens ophalen van rijkswaterstaat waterwebservices

Notes

Link: https://waterwebservices.rijkswaterstaat.nl/

Attributes

Name Type Description
data_adapter DataAdapter De data adapter voor het ophalen en opslaan van gegevens.
df_in Optional[pd.DataFrame] | None Het invoerdataframe.
df_out Optional[pd.DataFrame] | None Het uitvoerdataframe.
url_retrieve_observations str De url voor het ophalen van waarnemingen.

Methods

Name Description
create_dataframe Maakt een dataframe met waardes van de rws water webservices
create_json_list Maak een lijst van FEWS parameters om mee te sturen bij het ophalen van data.
log_exceptions Stuurt exceptions eerst naar de logger van de DataAdapter
run De runner van de Belasting WaterwebservicesRWS.

create_dataframe

loads.LoadsWaterwebservicesRWS.create_dataframe(
    options,
    calc_time,
    lst_data,
    df_in,
    global_variables,
)

Maakt een dataframe met waardes van de rws water webservices

Parameters

Name Type Description Default
options dict Een dictionary met opties uit de config required
calc_time datetime De huidige tijd required
lst_data list Een lijst met JSON data uit de post request required
df_in pd.DataFrame Het invoerdataframe required
global_variables dict De globale variabelen uit de config required

Returns

Name Type Description
dataframe pd.Dataframe Pandas dataframe geschikt voor uitvoer

create_json_list

loads.LoadsWaterwebservicesRWS.create_json_list(
    measurement,
    calc_time,
    global_variables,
    locations,
)

Maak een lijst van FEWS parameters om mee te sturen bij het ophalen van data.

Parameters

Name Type Description Default
measurement str De naam van de parameter die je wilt ophalen. required
calc_time datetime De huidige tijd in UTC. required
global_variables dict De globale variabelen uit de invoer yaml. required
locations pd.DataFrame Dataframe met de gewenste locaties. required

Returns

Name Type Description
list Lijst met parameters.

log_exceptions

loads.LoadsWaterwebservicesRWS.log_exceptions(method)

Stuurt exceptions eerst naar de logger van de DataAdapter

run

loads.LoadsWaterwebservicesRWS.run(input, output)

De runner van de Belasting WaterwebservicesRWS.

Parameters

Name Type Description Default
input str De naam van de invoerdataadapter. required
output str De naam van de uitvoerdataadapter. required

Raises

Name Type Description
UserWarning Wanneer de inputdata niet de kolom ‘measurement_location_id’ bevat. Wanneer de inputdata geen ‘measurement_location_code’ bevat. Wanneer de ‘measurement_location_code’ geen getal is. Wanneer de ‘LoadsWaterwebservicesRWS’ sectie niet aanwezig is in global_variables (config).