R/pobierz_rspo.R

In tzoltak/EWDrspo: Downloading the data of schools from RSPO website

#' @title Pobierz dane z RSPO
#' @description
#' Funkcja pobiera z Rejestru Szkół i Placówek Oświatowych dane:
#' \itemize{
#'   \item{szkół podstawowych,}
#'   \item{gimnazjów,}
#'   \item{liceów ogólnokształcących,}
#'   \item{techników,}
#'   \item{oraz zespołów, do których należą.}
#' }
#' @param rownolegle wartość logiczna - czy dane z poszczególnych województw
#' mają być zbierane równolegle (z użyciem pakietu \code{snow})?
#' @return data frame z bazą RSPO
#' @export
#' @importFrom snow makeCluster parLapply stopCluster
pobierz_rspo = function(rownolegle=TRUE) {
  # weryfikacja parametrów
  stopifnot(rownolegle %in% c(TRUE, FALSE))
  # sprawdzanie, czy mamy dostęp do wielowątkowości
  if (rownolegle) {
    rownolegle = "snow" %in% .packages(TRUE)
    if (!rownolegle) {
      warning(strwrap("Pakiet 'snow' jest niedostępny. Dane dotyczące poszczególnych województw będą pobierane sekwencyjnie, a nie równolegle.", prefix = " "),
              immediate. = TRUE)
    }
  }
  # odpalamy ściąganie
  kody = kody_wojewodztw()
  if (rownolegle) {  # równolegle
    cl = makeCluster(8, type = "SOCK")
    wojewodztwa = parLapply(cl, as.list(kody),
                            function(kod_woj) {
                              require(EWDrspo)
                              return(dane_wojewodztwa(NULL, kod_woj))
                            }
    )
    stopCluster(cl)
  } else { # lub sekwencyjnie
    wojewodztwa = lapply(as.list(kody), function(kod_woj) return(dane_wojewodztwa(NULL, kod_woj)))
  }

  rspo = polacz_tabele(wojewodztwa)
  rspo = zmien_tabele(tab = rspo)
  # zwracanie wyniku
  return(rspo)
}