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,
proces_type=None,
)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 |
| proces_type | str | None | Het proces type (zoals meting, astronomisch of verwacht), by default None | None |
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). |