LoadsWaterwebservicesRWS
loads.LoadsWaterwebservicesRWS()
Belastinggegevens ophalen van rijkswaterstaat waterwebservices
Notes
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
input, output) loads.LoadsWaterwebservicesRWS.run(
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). |