Surface Water

Define Helper Functions

cat_file_enumeration <- function(files) {
  cat(paste0(collapse = "\n\n", sprintf(
    "- [%s](%s/%s)", 
    files, 
    "https://kwb-r.github.io/wasserportal",
    files
  )))
}

Master Data

library(wasserportal)

stations <- wasserportal::get_stations()
#> Importing 10 station overviews from Wasserportal Berlin ... ok. (9.65 secs)
stations_list <- kwb.utils::selectElements(stations, "overview_list")

is_sw <- stringr::str_detect(names(stations_list), "surface")

files <- wasserportal::list_masters_data_to_csv(stations_list[is_sw])
#> Writing 'stations_surface-water_water-level.csv' ... ok. (0.05 secs) 
#> Writing 'stations_surface-water_flow.csv' ... ok. (0.00 secs) 
#> Writing 'stations_surface-water_temperature.csv' ... ok. (0.00 secs) 
#> Writing 'stations_surface-water_conductivity.csv' ... ok. (0.00 secs) 
#> Writing 'stations_surface-water_ph.csv' ... ok. (0.00 secs) 
#> Writing 'stations_surface-water_oxygen-concentration.csv' ... ok. (0.00 secs) 
#> Writing 'stations_surface-water_oxygen-saturation.csv' ... ok. (0.00 secs) 
#> Writing 'stations_surface-water_quality.csv' ... ok. (0.00 secs)

The following surface water master data .csv files are available for download:

Daily Surface Water Data & Overall Surface Water Quality

By running the code below all available daily surface water data of monitoring stations from Wasserportal Berlin will be downloaded and exported into one .json file for each parameter and all available monitoring stations.

variables <- wasserportal::get_surfacewater_variables()

variables
#>          surface_water.water_level                 surface_water.flow 
#>                              "ows"                              "odf" 
#>          surface_water.temperature         surface_water.conductivity 
#>                              "owt"                              "olf" 
#>                   surface_water.ph surface_water.oxygen_concentration 
#>                              "oph"                              "oog" 
#>    surface_water.oxygen_saturation 
#>                              "oos"

sw_data_daily_list <- wasserportal::get_daily_surfacewater_data(
  stations,
  variables
)
#> Importing 'surface_water.water_level' ... Station id: 5865900 (1/62)
#> Reading 'variable_ows' for station 5865900 (station_5865900) ... ok. (1.28 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5827103 (2/62)
#> Reading 'variable_ows' for station 5827103 (station_5827103) ... ok. (0.64 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5870400 (3/62)
#> Reading 'variable_ows' for station 5870400 (station_5870400) ... ok. (0.73 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5865300 (4/62)
#> Reading 'variable_ows' for station 5865300 (station_5865300) ... ok. (0.69 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5819900 (5/62)
#> Reading 'variable_ows' for station 5819900 (station_5819900) ... ok. (1.36 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5864801 (6/62)
#> Reading 'variable_ows' for station 5864801 (station_5864801) ... ok. (0.44 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5861101 (7/62)
#> Reading 'variable_ows' for station 5861101 (station_5861101) ... ok. (0.51 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800107 (8/62)
#> Reading 'variable_ows' for station 5800107 (station_5800107) ... ok. (1.37 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800317 (9/62)
#> Reading 'variable_ows' for station 5800317 (station_5800317) ... ok. (0.65 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867003 (10/62)
#> Reading 'variable_ows' for station 5867003 (station_5867003) ... ok. (0.47 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867401 (11/62)
#> Reading 'variable_ows' for station 5867401 (station_5867401) ... ok. (0.61 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800301 (12/62)
#> Reading 'variable_ows' for station 5800301 (station_5800301) ... ok. (0.51 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800302 (13/62)
#> Reading 'variable_ows' for station 5800302 (station_5800302) ... ok. (0.47 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5863000 (14/62)
#> Reading 'variable_ows' for station 5863000 (station_5863000) ... ok. (0.47 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867900 (15/62)
#> Reading 'variable_ows' for station 5867900 (station_5867900) ... ok. (0.73 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5827101 (16/62)
#> Reading 'variable_ows' for station 5827101 (station_5827101) ... ok. (0.81 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800320 (17/62)
#> Reading 'variable_ows' for station 5800320 (station_5800320) ... ok. (0.42 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800313 (18/62)
#> Reading 'variable_ows' for station 5800313 (station_5800313) ... ok. (0.43 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5860900 (19/62)
#> Reading 'variable_ows' for station 5860900 (station_5860900) ... ok. (0.43 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867101 (20/62)
#> Reading 'variable_ows' for station 5867101 (station_5867101) ... ok. (0.47 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5826702 (21/62)
#> Reading 'variable_ows' for station 5826702 (station_5826702) ... ok. (0.76 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800305 (22/62)
#> Reading 'variable_ows' for station 5800305 (station_5800305) ... ok. (1.35 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800304 (23/62)
#> Reading 'variable_ows' for station 5800304 (station_5800304) ... ok. (0.50 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800306 (24/62)
#> Reading 'variable_ows' for station 5800306 (station_5800306) ... ok. (0.54 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5861000 (25/62)
#> Reading 'variable_ows' for station 5861000 (station_5861000) ... ok. (0.90 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867300 (26/62)
#> Reading 'variable_ows' for station 5867300 (station_5867300) ... ok. (0.73 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5864700 (27/62)
#> Reading 'variable_ows' for station 5864700 (station_5864700) ... ok. (0.36 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5865000 (28/62)
#> Reading 'variable_ows' for station 5865000 (station_5865000) ... ok. (0.39 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5865200 (29/62)
#> Reading 'variable_ows' for station 5865200 (station_5865200) ... ok. (0.45 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800308 (30/62)
#> Reading 'variable_ows' for station 5800308 (station_5800308) ... ok. (0.66 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867100 (31/62)
#> Reading 'variable_ows' for station 5867100 (station_5867100) ... ok. (0.73 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5869700 (32/62)
#> Reading 'variable_ows' for station 5869700 (station_5869700) ... ok. (0.46 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867500 (33/62)
#> Reading 'variable_ows' for station 5867500 (station_5867500) ... ok. (0.99 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5870100 (34/62)
#> Reading 'variable_ows' for station 5870100 (station_5870100) ... ok. (1.23 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800309 (35/62)
#> Reading 'variable_ows' for station 5800309 (station_5800309) ... ok. (1.15 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5819901 (36/62)
#> Reading 'variable_ows' for station 5819901 (station_5819901) ... ok. (0.58 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800318 (37/62)
#> Reading 'variable_ows' for station 5800318 (station_5800318) ... ok. (0.50 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5826701 (38/62)
#> Reading 'variable_ows' for station 5826701 (station_5826701) ... ok. (0.74 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800315 (39/62)
#> Reading 'variable_ows' for station 5800315 (station_5800315) ... ok. (0.51 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800316 (40/62)
#> Reading 'variable_ows' for station 5800316 (station_5800316) ... ok. (0.45 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867700 (41/62)
#> Reading 'variable_ows' for station 5867700 (station_5867700) ... ok. (0.63 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5803500 (42/62)
#> Reading 'variable_ows' for station 5803500 (station_5803500) ... ok. (1.35 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800312 (43/62)
#> Reading 'variable_ows' for station 5800312 (station_5800312) ... ok. (0.48 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867000 (44/62)
#> Reading 'variable_ows' for station 5867000 (station_5867000) ... ok. (0.81 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800106 (45/62)
#> Reading 'variable_ows' for station 5800106 (station_5800106) ... ok. (0.52 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5866700 (46/62)
#> Reading 'variable_ows' for station 5866700 (station_5866700) ... ok. (0.69 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5866800 (47/62)
#> Reading 'variable_ows' for station 5866800 (station_5866800) ... ok. (1.37 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5862811 (48/62)
#> Reading 'variable_ows' for station 5862811 (station_5862811) ... ok. (0.64 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867600 (49/62)
#> Reading 'variable_ows' for station 5867600 (station_5867600) ... ok. (0.35 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5827700 (50/62)
#> Reading 'variable_ows' for station 5827700 (station_5827700) ... ok. (1.38 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5820000 (51/62)
#> Reading 'variable_ows' for station 5820000 (station_5820000) ... ok. (1.01 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5815911 (52/62)
#> Reading 'variable_ows' for station 5815911 (station_5815911) ... ok. (0.67 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5803200 (53/62)
#> Reading 'variable_ows' for station 5803200 (station_5803200) ... ok. (1.37 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867301 (54/62)
#> Reading 'variable_ows' for station 5867301 (station_5867301) ... ok. (0.46 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867201 (55/62)
#> Reading 'variable_ows' for station 5867201 (station_5867201) ... ok. (0.74 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867202 (56/62)
#> Reading 'variable_ows' for station 5867202 (station_5867202) ... ok. (0.74 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800310 (57/62)
#> Reading 'variable_ows' for station 5800310 (station_5800310) ... ok. (0.55 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800314 (58/62)
#> Reading 'variable_ows' for station 5800314 (station_5800314) ... ok. (0.87 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5861200 (59/62)
#> Reading 'variable_ows' for station 5861200 (station_5861200) ... ok. (0.88 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867001 (60/62)
#> Reading 'variable_ows' for station 5867001 (station_5867001) ... ok. (0.41 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5864800 (61/62)
#> Reading 'variable_ows' for station 5864800 (station_5864800) ... ok. (0.67 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5866301 (62/62)
#> Reading 'variable_ows' for station 5866301 (station_5866301) ... ok. (0.72 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> ok. (48.25 secs) 
#> Importing 'surface_water.flow' ... Station id: 5827103 (1/16)
#> Reading 'variable_odf' for station 5827103 (station_5827103) ... ok. (0.59 secs) 
#> Removing 1 elements that are empty or failed (variables: 'odf') ... ok. (0.00 secs)
#> No remaining data frames. Returning NULL.
#> Station id: 5870400 (2/16)
#> Reading 'variable_odf' for station 5870400 (station_5870400) ... ok. (0.42 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5865300 (3/16)
#> Reading 'variable_odf' for station 5865300 (station_5865300) ... ok. (0.67 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5864801 (4/16)
#> Reading 'variable_odf' for station 5864801 (station_5864801) ... ok. (0.42 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867401 (5/16)
#> Reading 'variable_odf' for station 5867401 (station_5867401) ... ok. (0.57 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867900 (6/16)
#> Reading 'variable_odf' for station 5867900 (station_5867900) ... ok. (0.68 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5827101 (7/16)
#> Reading 'variable_odf' for station 5827101 (station_5827101) ... ok. (0.42 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5870100 (8/16)
#> Reading 'variable_odf' for station 5870100 (station_5870100) ... ok. (0.70 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5826701 (9/16)
#> Reading 'variable_odf' for station 5826701 (station_5826701) ... ok. (0.47 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5862811 (10/16)
#> Reading 'variable_odf' for station 5862811 (station_5862811) ... ok. (0.61 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5827700 (11/16)
#> Reading 'variable_odf' for station 5827700 (station_5827700) ... ok. (1.35 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5815911 (12/16)
#> Reading 'variable_odf' for station 5815911 (station_5815911) ... ok. (0.65 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5803200 (13/16)
#> Reading 'variable_odf' for station 5803200 (station_5803200) ... ok. (1.62 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5861200 (14/16)
#> Reading 'variable_odf' for station 5861200 (station_5861200) ... ok. (0.65 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5864800 (15/16)
#> Reading 'variable_odf' for station 5864800 (station_5864800) ... ok. (0.59 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5866301 (16/16)
#> Reading 'variable_odf' for station 5866301 (station_5866301) ... ok. (0.68 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Empty data frame when looping through 'sw_data_list' in sw_data_list_to_df()
#> Warning in min(which(stringr::str_detect(metadata, ":"))): no non-missing
#> arguments to min; returning Inf
#> ok. (11.88 secs) 
#> Importing 'surface_water.temperature' ... Station id: 601 (1/58)
#> Reading 'variable_owt' for station 601 (station_601) ... ok. (0.95 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 151 (2/58)
#> Reading 'variable_owt' for station 151 (station_151) ... ok. (0.84 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 153 (3/58)
#> Reading 'variable_owt' for station 153 (station_153) ... ok. (0.63 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 509 (4/58)
#> Reading 'variable_owt' for station 509 (station_509) ... ok. (0.93 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 504 (5/58)
#> Reading 'variable_owt' for station 504 (station_504) ... ok. (0.90 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 414 (6/58)
#> Reading 'variable_owt' for station 414 (station_414) ... ok. (0.88 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 141 (7/58)
#> Reading 'variable_owt' for station 141 (station_141) ... ok. (1.12 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 111 (8/58)
#> Reading 'variable_owt' for station 111 (station_111) ... ok. (1.18 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 211 (9/58)
#> Reading 'variable_owt' for station 211 (station_211) ... ok. (1.17 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 161 (10/58)
#> Reading 'variable_owt' for station 161 (station_161) ... ok. (1.46 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 421 (11/58)
#> Reading 'variable_owt' for station 421 (station_421) ... ok. (1.57 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5865300 (12/58)
#> Reading 'variable_owt' for station 5865300 (station_5865300) ... ok. (0.51 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5861101 (13/58)
#> Reading 'variable_owt' for station 5861101 (station_5861101) ... ok. (0.43 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800107 (14/58)
#> Reading 'variable_owt' for station 5800107 (station_5800107) ... ok. (0.52 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800317 (15/58)
#> Reading 'variable_owt' for station 5800317 (station_5800317) ... ok. (0.56 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867003 (16/58)
#> Reading 'variable_owt' for station 5867003 (station_5867003) ... ok. (0.56 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867401 (17/58)
#> Reading 'variable_owt' for station 5867401 (station_5867401) ... ok. (0.54 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800302 (18/58)
#> Reading 'variable_owt' for station 5800302 (station_5800302) ... ok. (0.56 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5863000 (19/58)
#> Reading 'variable_owt' for station 5863000 (station_5863000) ... ok. (0.55 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867900 (20/58)
#> Reading 'variable_owt' for station 5867900 (station_5867900) ... ok. (0.54 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5827101 (21/58)
#> Reading 'variable_owt' for station 5827101 (station_5827101) ... ok. (0.62 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800320 (22/58)
#> Reading 'variable_owt' for station 5800320 (station_5800320) ... ok. (0.50 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867101 (23/58)
#> Reading 'variable_owt' for station 5867101 (station_5867101) ... ok. (0.55 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800305 (24/58)
#> Reading 'variable_owt' for station 5800305 (station_5800305) ... ok. (0.87 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800304 (25/58)
#> Reading 'variable_owt' for station 5800304 (station_5800304) ... ok. (0.56 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800306 (26/58)
#> Reading 'variable_owt' for station 5800306 (station_5800306) ... ok. (0.52 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867300 (27/58)
#> Reading 'variable_owt' for station 5867300 (station_5867300) ... ok. (0.54 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5864700 (28/58)
#> Reading 'variable_owt' for station 5864700 (station_5864700) ... ok. (0.35 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5865000 (29/58)
#> Reading 'variable_owt' for station 5865000 (station_5865000) ... ok. (0.40 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5865200 (30/58)
#> Reading 'variable_owt' for station 5865200 (station_5865200) ... ok. (0.43 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800308 (31/58)
#> Reading 'variable_owt' for station 5800308 (station_5800308) ... ok. (0.25 secs) 
#> Removing 1 elements that are empty or failed (variables: 'owt') ... ok. (0.00 secs)
#> No remaining data frames. Returning NULL.
#> Station id: 5867100 (32/58)
#> Reading 'variable_owt' for station 5867100 (station_5867100) ... ok. (0.50 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5869700 (33/58)
#> Reading 'variable_owt' for station 5869700 (station_5869700) ... ok. (0.53 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867500 (34/58)
#> Reading 'variable_owt' for station 5867500 (station_5867500) ... ok. (0.50 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5870100 (35/58)
#> Reading 'variable_owt' for station 5870100 (station_5870100) ... ok. (0.52 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800309 (36/58)
#> Reading 'variable_owt' for station 5800309 (station_5800309) ... ok. (0.46 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5819901 (37/58)
#> Reading 'variable_owt' for station 5819901 (station_5819901) ... ok. (0.40 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800318 (38/58)
#> Reading 'variable_owt' for station 5800318 (station_5800318) ... ok. (0.55 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5826701 (39/58)
#> Reading 'variable_owt' for station 5826701 (station_5826701) ... ok. (0.48 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800315 (40/58)
#> Reading 'variable_owt' for station 5800315 (station_5800315) ... ok. (0.52 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800316 (41/58)
#> Reading 'variable_owt' for station 5800316 (station_5800316) ... ok. (0.54 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867700 (42/58)
#> Reading 'variable_owt' for station 5867700 (station_5867700) ... ok. (0.51 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5803500 (43/58)
#> Reading 'variable_owt' for station 5803500 (station_5803500) ... ok. (0.57 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800312 (44/58)
#> Reading 'variable_owt' for station 5800312 (station_5800312) ... ok. (0.53 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867000 (45/58)
#> Reading 'variable_owt' for station 5867000 (station_5867000) ... ok. (0.50 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800106 (46/58)
#> Reading 'variable_owt' for station 5800106 (station_5800106) ... ok. (0.56 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5866700 (47/58)
#> Reading 'variable_owt' for station 5866700 (station_5866700) ... ok. (0.54 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5866800 (48/58)
#> Reading 'variable_owt' for station 5866800 (station_5866800) ... ok. (0.53 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867600 (49/58)
#> Reading 'variable_owt' for station 5867600 (station_5867600) ... ok. (0.35 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5827700 (50/58)
#> Reading 'variable_owt' for station 5827700 (station_5827700) ... ok. (0.54 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5820000 (51/58)
#> Reading 'variable_owt' for station 5820000 (station_5820000) ... ok. (0.55 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5803200 (52/58)
#> Reading 'variable_owt' for station 5803200 (station_5803200) ... ok. (0.54 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867301 (53/58)
#> Reading 'variable_owt' for station 5867301 (station_5867301) ... ok. (0.54 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867201 (54/58)
#> Reading 'variable_owt' for station 5867201 (station_5867201) ... ok. (0.54 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5867202 (55/58)
#> Reading 'variable_owt' for station 5867202 (station_5867202) ... ok. (0.54 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5800310 (56/58)
#> Reading 'variable_owt' for station 5800310 (station_5800310) ... ok. (0.52 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5861200 (57/58)
#> Reading 'variable_owt' for station 5861200 (station_5861200) ... ok. (0.51 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 5864800 (58/58)
#> Reading 'variable_owt' for station 5864800 (station_5864800) ... ok. (0.53 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Empty data frame when looping through 'sw_data_list' in sw_data_list_to_df()
#> Warning in min(which(stringr::str_detect(metadata, ":"))): no non-missing
#> arguments to min; returning Inf
#> ok. (39.05 secs) 
#> Importing 'surface_water.conductivity' ... Station id: 601 (1/11)
#> Reading 'variable_olf' for station 601 (station_601) ... ok. (0.87 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 151 (2/11)
#> Reading 'variable_olf' for station 151 (station_151) ... ok. (1.06 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 153 (3/11)
#> Reading 'variable_olf' for station 153 (station_153) ... ok. (0.58 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 509 (4/11)
#> Reading 'variable_olf' for station 509 (station_509) ... ok. (0.88 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 504 (5/11)
#> Reading 'variable_olf' for station 504 (station_504) ... ok. (0.86 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 414 (6/11)
#> Reading 'variable_olf' for station 414 (station_414) ... ok. (0.84 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 141 (7/11)
#> Reading 'variable_olf' for station 141 (station_141) ... ok. (1.10 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 111 (8/11)
#> Reading 'variable_olf' for station 111 (station_111) ... ok. (1.14 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 211 (9/11)
#> Reading 'variable_olf' for station 211 (station_211) ... ok. (1.13 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 161 (10/11)
#> Reading 'variable_olf' for station 161 (station_161) ... ok. (1.42 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 421 (11/11)
#> Reading 'variable_olf' for station 421 (station_421) ... ok. (1.50 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> ok. (12.41 secs) 
#> Importing 'surface_water.ph' ... Station id: 601 (1/11)
#> Reading 'variable_oph' for station 601 (station_601) ... ok. (0.90 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 151 (2/11)
#> Reading 'variable_oph' for station 151 (station_151) ... ok. (0.79 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 153 (3/11)
#> Reading 'variable_oph' for station 153 (station_153) ... ok. (0.58 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 509 (4/11)
#> Reading 'variable_oph' for station 509 (station_509) ... ok. (0.87 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 504 (5/11)
#> Reading 'variable_oph' for station 504 (station_504) ... ok. (0.87 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 414 (6/11)
#> Reading 'variable_oph' for station 414 (station_414) ... ok. (0.85 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 141 (7/11)
#> Reading 'variable_oph' for station 141 (station_141) ... ok. (1.10 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 111 (8/11)
#> Reading 'variable_oph' for station 111 (station_111) ... ok. (1.15 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 211 (9/11)
#> Reading 'variable_oph' for station 211 (station_211) ... ok. (1.17 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 161 (10/11)
#> Reading 'variable_oph' for station 161 (station_161) ... ok. (1.43 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 421 (11/11)
#> Reading 'variable_oph' for station 421 (station_421) ... ok. (1.53 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> ok. (12.15 secs) 
#> Importing 'surface_water.oxygen_concentration' ... Station id: 601 (1/11)
#> Reading 'variable_oog' for station 601 (station_601) ... ok. (0.91 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 151 (2/11)
#> Reading 'variable_oog' for station 151 (station_151) ... ok. (0.81 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 153 (3/11)
#> Reading 'variable_oog' for station 153 (station_153) ... ok. (0.57 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 509 (4/11)
#> Reading 'variable_oog' for station 509 (station_509) ... ok. (0.87 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 504 (5/11)
#> Reading 'variable_oog' for station 504 (station_504) ... ok. (0.87 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 414 (6/11)
#> Reading 'variable_oog' for station 414 (station_414) ... ok. (0.85 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 141 (7/11)
#> Reading 'variable_oog' for station 141 (station_141) ... ok. (1.10 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 111 (8/11)
#> Reading 'variable_oog' for station 111 (station_111) ... ok. (1.13 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 211 (9/11)
#> Reading 'variable_oog' for station 211 (station_211) ... ok. (1.14 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 161 (10/11)
#> Reading 'variable_oog' for station 161 (station_161) ... ok. (1.43 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 421 (11/11)
#> Reading 'variable_oog' for station 421 (station_421) ... ok. (1.51 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> ok. (12.18 secs) 
#> Importing 'surface_water.oxygen_saturation' ... Station id: 601 (1/11)
#> Reading 'variable_oos' for station 601 (station_601) ... ok. (0.82 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 151 (2/11)
#> Reading 'variable_oos' for station 151 (station_151) ... ok. (0.77 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 153 (3/11)
#> Reading 'variable_oos' for station 153 (station_153) ... ok. (0.57 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 509 (4/11)
#> Reading 'variable_oos' for station 509 (station_509) ... ok. (0.81 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 504 (5/11)
#> Reading 'variable_oos' for station 504 (station_504) ... ok. (1.21 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 414 (6/11)
#> Reading 'variable_oos' for station 414 (station_414) ... ok. (0.83 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 141 (7/11)
#> Reading 'variable_oos' for station 141 (station_141) ... ok. (0.98 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 111 (8/11)
#> Reading 'variable_oos' for station 111 (station_111) ... ok. (1.01 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 211 (9/11)
#> Reading 'variable_oos' for station 211 (station_211) ... ok. (1.01 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 161 (10/11)
#> Reading 'variable_oos' for station 161 (station_161) ... ok. (1.29 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> Station id: 421 (11/11)
#> Reading 'variable_oos' for station 421 (station_421) ... ok. (1.42 secs)
#> Warning in warning_not_implemented("merge_raw_results_daily()"):
#> merge_raw_results_daily() is not yet implemented. Returning raw data
#> ok. (11.68 secs)

files <- wasserportal::list_timeseries_data_to_zip(sw_data_daily_list)
#> Writing 'daily_surface-water_water-level.zip' ... ok. (0.91 secs) 
#> Writing 'daily_surface-water_flow.zip' ... ok. (0.20 secs) 
#> Writing 'daily_surface-water_temperature.zip' ... ok. (0.79 secs) 
#> Writing 'daily_surface-water_conductivity.zip' ... ok. (0.27 secs) 
#> Writing 'daily_surface-water_ph.zip' ... ok. (0.27 secs) 
#> Writing 'daily_surface-water_oxygen-concentration.zip' ... ok. (0.29 secs) 
#> Writing 'daily_surface-water_oxygen-saturation.zip' ... ok. (0.29 secs)
files
#> [1] "daily_surface-water_water-level.zip"         
#> [2] "daily_surface-water_flow.zip"                
#> [3] "daily_surface-water_temperature.zip"         
#> [4] "daily_surface-water_conductivity.zip"        
#> [5] "daily_surface-water_ph.zip"                  
#> [6] "daily_surface-water_oxygen-concentration.zip"
#> [7] "daily_surface-water_oxygen-saturation.zip"

# Data availability per parameter
sw_data_daily_list %>%
  dplyr::bind_rows() %>% 
  dplyr::count(Parameter, Einheit)
#>             Parameter Einheit      n
#> 1          Durchfluss    m³/s 116757
#> 2       Leitfähigkeit   µS/cm  84397
#> 3    Sauerstoffgehalt    mg/l  83366
#> 4 Sauerstoffsättigung       %  83093
#> 5         Wasserstand      cm 530474
#> 6   Wasssertemperatur      °C 210598
#> 7             pH-Wert          84101


station_ids <- stations$overview_list$surface_water.quality$Messstellennummer

swq_data <- wasserportal::get_surfacewater_qualities(station_ids)
#> Downloading surface water quality data ... 
#> 01/55: station_id = '102' ... ok. (0.42 secs) 
#> 02/55: station_id = '105' ... ok. (1.46 secs) 
#> 03/55: station_id = '110' ... ok. (3.17 secs) 
#> 04/55: station_id = '115' ... ok. (2.38 secs) 
#> 05/55: station_id = '120' ... ok. (1.93 secs) 
#> 06/55: station_id = '125' ... ok. (2.00 secs) 
#> 07/55: station_id = '130' ... ok. (3.32 secs) 
#> 08/55: station_id = '135' ... ok. (1.94 secs) 
#> 09/55: station_id = '140' ... ok. (3.49 secs) 
#> 10/55: station_id = '150' ... ok. (2.51 secs) 
#> 11/55: station_id = '160' ... ok. (5.94 secs) 
#> 12/55: station_id = '215' ... ok. (4.12 secs) 
#> 13/55: station_id = '220' ... ok. (1.67 secs) 
#> 14/55: station_id = '225' ... ok. (1.39 secs) 
#> 15/55: station_id = '228' ... ok. (0.30 secs) 
#> 16/55: station_id = '230' ... ok. (2.26 secs) 
#> 17/55: station_id = '305' ... ok. (2.52 secs) 
#> 18/55: station_id = '311' ... ok. (0.97 secs) 
#> 19/55: station_id = '315' ... ok. (1.65 secs) 
#> 20/55: station_id = '316' ... ok. (0.40 secs) 
#> 21/55: station_id = '320' ... ok. (4.27 secs) 
#> 22/55: station_id = '325' ... ok. (2.52 secs) 
#> 23/55: station_id = '330' ... ok. (2.22 secs) 
#> 24/55: station_id = '340' ... ok. (1.92 secs) 
#> 25/55: station_id = '345' ... ok. (3.99 secs) 
#> 26/55: station_id = '350' ... ok. (2.06 secs) 
#> 27/55: station_id = '355' ... ok. (2.14 secs) 
#> 28/55: station_id = '407' ... ok. (0.69 secs) 
#> 29/55: station_id = '410' ... ok. (3.19 secs) 
#> 30/55: station_id = '415' ... ok. (2.04 secs) 
#> 31/55: station_id = '420' ... ok. (3.59 secs) 
#> 32/55: station_id = '430' ... ok. (7.64 secs) 
#> 33/55: station_id = '505' ... ok. (2.24 secs) 
#> 34/55: station_id = '510' ... ok. (1.91 secs) 
#> 35/55: station_id = '515' ... ok. (2.66 secs) 
#> 36/55: station_id = '605' ... ok. (2.22 secs) 
#> 37/55: station_id = '606' ... ok. (0.41 secs) 
#> 38/55: station_id = '610' ... ok. (1.80 secs) 
#> 39/55: station_id = '710' ... ok. (2.84 secs) 
#> 40/55: station_id = '714' ... ok. (0.41 secs) 
#> 41/55: station_id = '715' ... ok. (1.55 secs) 
#> 42/55: station_id = '718' ... ok. (0.85 secs) 
#> 43/55: station_id = '719' ... ok. (1.19 secs) 
#> 44/55: station_id = '723' ... ok. (0.58 secs) 
#> 45/55: station_id = '725' ... ok. (1.51 secs) 
#> 46/55: station_id = '728' ... ok. (1.97 secs) 
#> 47/55: station_id = '729' ... ok. (0.70 secs) 
#> 48/55: station_id = '730' ... ok. (2.09 secs) 
#> 49/55: station_id = '740' ... ok. (0.97 secs) 
#> 50/55: station_id = '741' ... ok. (0.82 secs) 
#> 51/55: station_id = '742' ... ok. (0.95 secs) 
#> 52/55: station_id = '803' ... ok. (1.46 secs) 
#> 53/55: station_id = '805' ... ok. (1.25 secs) 
#> 54/55: station_id = '807' ... ok. (0.84 secs) 
#> 55/55: station_id = '815' ... ok. (1.41 secs) 
#> ok. (1.88 mins)

files1 <- wasserportal::list_timeseries_data_to_zip(
  list("surface-water_quality" = swq_data)
  )
#> Writing 'daily_surface-water-quality.zip' ... ok. (1.10 secs)

files2 <- "surface-water_quality.zip"

file.rename(files1, files2)
#> [1] TRUE

The following .zip files are available for download:

Daily Surface Water Levels

swl_master <- wasserportal::get_wasserportal_masters_data(
  master_urls = stations_list$surface_water.water_level %>%
    dplyr::filter(.data$Betreiber == "Land Berlin") %>%
    dplyr::pull(.data$stammdaten_link)
)
#> Importing master data for 62 stations from Wasserportal Berlin ... ok. (39.51 secs)

column_level_zero <- "Pegelnullpunkt_m_NHN"
  
swl_data <- sw_data_daily_list$surface_water.water_level %>% 
  dplyr::select(where(~!all(is.na(.x)))) %>%
  dplyr::left_join(
    kwb.utils::selectColumns(swl_master, c("Nummer", column_level_zero)),
    by = c(Messstellennummer = "Nummer")
  ) %>%
  dplyr::mutate(
    Tagesmittelwert_Pegelstand_mNN = as.numeric(.data[[column_level_zero]]) + 
      .data$Tagesmittelwert / 100
  ) %>%
  ### remove -777 for messstellennummer 5867000 (few values in 2000) resulted by
  ### step above
  dplyr::filter(.data[["Tagesmittelwert_Pegelstand_mNN"]] != -777) %>%
  kwb.utils::removeColumns(column_level_zero)

str(swl_data)
#> 'data.frame':    529392 obs. of  6 variables:
#>  $ Messstellennummer             : chr  "5865900" "5865900" "5865900" "5865900" ...
#>  $ Datum                         : Date, format: "1999-11-01" "1999-11-02" ...
#>  $ Tagesmittelwert               : int  16 23 19 17 17 15 14 14 19 19 ...
#>  $ Parameter                     : chr  "Wasserstand" "Wasserstand" "Wasserstand" "Wasserstand" ...
#>  $ Einheit                       : chr  "cm" "cm" "cm" "cm" ...
#>  $ Tagesmittelwert_Pegelstand_mNN: num  45.8 45.8 45.8 45.8 45.8 ...
#>  - attr(*, "metadata")= chr [1:5] "Stationsnummer: 5865900" "Stationsname: Allee der Kosmonauten" "Gewässer: M.-H.-Grenzgr." "Wasserstand in cm" ...

Michael Rustler

2024-07-09 05:31:39.135014

Define Helper Functions

Master Data

Daily Surface Water Data & Overall Surface Water Quality

Daily Surface Water Levels