R/geocode.R
In scottcame/geocode: Interface to free geocoding services
# Copyright 2017 Scott Came Consulting LLC
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#' Geocode addresses using a hierarchy of geocoders, where later geocoders fill in gaps that earlier ones couldn't handle
#' @param geocoders the geocoders to try, in order
#' @param addresses the list of addresses to geocode
#' @param notificationFunction a function called after each geocode to enable logging, etc.
#' @param sleep number of seconds to sleep between requests (to avoid exceeding rate limits)
#' @param ... additional named arguments passed to specific geocoder functions
#' @import dplyr
#' @import tibble
#' @return a data frame with the results of geocoding, with the SourceIndex column providing the index into the input address vector
#' @export
geocode <- function(addresses, geocoders=c('Census', 'Nominatim', 'Google'), sleep=1.5, notificationFunction=emptyFunction, ...) {
ret <- tibble()
addresses <- trimws(addresses)
uniqueAddresses <- unique(addresses) %>% na.omit() %>% as.vector()
indices <- seq(length(uniqueAddresses))
names(indices) <- uniqueAddresses
missings <- uniqueAddresses
for (geocoder in geocoders) {
if (length(uniqueAddresses) > 0) {
f <- paste0('geocode', geocoder)
args <- list()
args$addresses <- missings
args$sleep <- sleep
args$notificationFunction <- notificationFunction
args <- c(args, list(...))
ret <- bind_rows(ret, do.call(f, args))
successes <- character()
if (nrow(ret)) {
successes <- ret$InputAddress
}
missings <- setdiff(uniqueAddresses, successes)
}
}
if (nrow(ret)) {
ret <- select(ret, -SourceIndex) %>%
right_join(tibble(InputAddress=addresses) %>% mutate(SourceIndex=row_number()), by='InputAddress') %>%
filter(!is.na(Source))
}
ret
}
#' Geocode addresses using an ArcGIS "findAddressCandidates" GeocodeServer service
#' @param addresses a vector of address strings
#' @param sleep number of seconds to sleep between requests (to avoid exceeding rate limits)
#' @param arcgisServiceURL base URL of the service address, up to and including the last forward slash preceding "findAddressCandidates?"
#' @param approximationThreshold the score value in the ArcGIS response below which a candidate is considered approximate
#' @param notificationFunction a function called after each geocode to enable logging, etc.
#' @param ... unused
#' @importFrom jsonlite fromJSON
#' @import dplyr
#' @import tibble
#' @importFrom purrr map2_df
#' @return a data frame with the results of geocoding, with the SourceIndex column providing the index into the input address vector
#' @export
geocodeArcGIS <- function(addresses, arcgisServiceURL='http://geocode.arcgis.com/arcgis/rest/services/World/GeocodeServer/', approximationThreshold=85,
sleep=1.5, notificationFunction=emptyFunction, ...) {
baseURL <- paste0(arcgisServiceURL, 'findAddressCandidates?singleLine=')
indices <- seq(length(addresses))
sel <- !grepl(x=trimws(addresses), pattern='^[0-9]+$')
indices <- indices[sel]
addresses <- addresses[sel]
map2_df(addresses, indices, function(address, index) {
url <- paste0(baseURL, URLencode(address), '&f=json&outFields=AddNum,StPreDir,StName,StType,StDir,City,Region,Postal,Addr_type')
content <- fromJSON(url, simplifyDataFrame=FALSE)
ret <- NULL
if (!is.null(content)) {
candidates <- content$candidates
if (length(candidates) > 0) {
candidate <- candidates[[1]]
street <- trimws(paste(candidate$attributes$StPreDir, candidate$attributes$StName, candidate$attributes$StType, candidate$attributes$StDir))
ret <- tibble(
Number=candidate$attributes$AddNum,
Street=street,
City=candidate$attributes$City,
State=candidate$attributes$Region,
Zip=candidate$attributes$Postal,
Latitude=candidate$location$y,
Longitude=candidate$location$x,
InputAddress=address,
Approximate=FALSE,
Source='ArcGIS',
SourceIndex=index,
Addr_type=candidate$attributes$Addr_type,
Score=candidate$score
) %>%
mutate_if(is.character, function(v) {ifelse(trimws(v)=='', NA_character_, v)}) %>%
mutate(accurate_=candidate$score >= approximationThreshold &
(Addr_type %in% c('StreetInt', 'POI') | (Addr_type %in% c('StreetName', 'PointAddress', 'StreetAddress') & !is.na(Number)))) %>%
mutate(Approximate=!accurate_) %>% select(-Addr_type, -accurate_, -Score)
}
}
Sys.sleep(sleep * (index < max(indices)))
notificationFunction(address, index, ret)
ret
})
}
#' Geocode addresses using the Census Geocoder
#' @param addresses a vector of address strings
#' @param sleep number of seconds to sleep between requests (to avoid exceeding rate limits)
#' @param notificationFunction a function called after each geocode to enable logging, etc.
#' @param ... unused
#' @importFrom jsonlite fromJSON
#' @import dplyr
#' @import tibble
#' @importFrom purrr map2_df
#' @return a data frame with the results of geocoding, with the SourceIndex column providing the index into the input address vector
#' @export
geocodeCensus <- function(addresses, sleep=1.5, notificationFunction=emptyFunction, ...) {
baseURL <- 'https://geocoding.geo.census.gov/geocoder/locations/onelineaddress?format=json&benchmark=Public_AR_Current&address='
indices <- seq(length(addresses))
sel <- !grepl(x=trimws(addresses), pattern='^[0-9]+$')
indices <- indices[sel]
addresses <- addresses[sel]
map2_df(addresses, indices, function(address, index) {
url <- paste0(baseURL, URLencode(address))
content <- fromJSON(url, simplifyDataFrame=FALSE)
ret <- NULL
if (!is.null(content)) {
result <- content$result
if (!is.null(result)) {
addressMatches <- result$addressMatches
if (length(addressMatches) > 0) {
matchComponents <- addressMatches[[1]]$addressComponents
coords <- addressMatches[[1]]$coordinates
ret <- tibble(
Number = paste0(matchComponents$fromAddress, '-', matchComponents$toAddress),
Street = gsub(x=trimws(paste0(matchComponents$preQualifier, ' ',
matchComponents$preDirection, ' ',
matchComponents$preType, ' ',
matchComponents$streetName, ' ',
matchComponents$suffixType, ' ',
matchComponents$suffixQualifier, ' ',
matchComponents$suffixDirection)),
pattern='[ ]+', replacement=' '),
City = matchComponents$city,
State = matchComponents$state,
Zip = matchComponents$zip,
Latitude=as.numeric(coords$y),
Longitude=as.numeric(coords$x),
InputAddress=address,
Approximate=(FALSE),
Source='Census',
SourceIndex=index
)
}
}
Sys.sleep(sleep * (index < max(indices)))
}
notificationFunction(address, index, ret)
ret
})
}
#' Geocode addreses using the Nominatim service provided by Open Street Map
#' @param addresses a vector of address strings
#' @param nominatimServiceURL the base address of the nominatim service to use; include everything that precedes the ?
#' @param sleep number of seconds to sleep between requests (to avoid exceeding rate limits)
#' @param notificationFunction a function called after each geocode to enable logging, etc.
#' @param ... unused
#' @importFrom jsonlite fromJSON
#' @import dplyr
#' @import tibble
#' @importFrom purrr map2_df
#' @return a data frame with the results of geocoding, with the SourceIndex column providing the index into the input address vector
#' @export
geocodeNominatim <- function(addresses, nominatimServiceURL='http://nominatim.openstreetmap.org', sleep=1.5, notificationFunction=emptyFunction, ...) {
baseURL <- paste0(nominatimServiceURL, '?addressdetails=1&format=json&q=')
indices <- seq(length(addresses))
sel <- !grepl(x=trimws(addresses), pattern='^[0-9]+$')
indices <- indices[sel]
addresses <- addresses[sel]
map2_df(addresses, indices, function(address, index) {
url <- paste0(baseURL, URLencode(address))
content <- fromJSON(url, simplifyDataFrame=FALSE)
ret <- NULL
if (length(content) > 0) {
j <- content[[1]]
ret <- tibble(
Number = ifelse(is.null(j$address$house_number), NA_character_, j$address$house_number),
Street = ifelse(is.null(j$address$road), NA_character_, j$address$road),
City = ifelse(is.null(j$address$city), NA_character_, j$address$city),
State = ifelse(is.null(j$address$state), NA_character_, j$address$state),
Zip = ifelse(is.null(j$address$postcode), NA_character_, j$address$postcode),
Latitude=as.numeric(j$lat),
Longitude=as.numeric(j$lon),
InputAddress=address,
Approximate=(is.null(j$address$house_number)),
Source='Nominatim',
SourceIndex=index
)
Sys.sleep(sleep * (index < max(indices)))
}
notificationFunction(address, index, ret)
ret
})
}
#' Geocode addreses using the Google geocoding API
#' @param addresses a vector of address strings
#' @param sleep number of seconds to sleep between requests (to avoid exceeding rate limits)
#' @param notificationFunction a function called after each geocode to enable logging, etc.
#' @param apiKey the Google API Key to use, or null (the default) to use no key
#' @param ... unused
#' @importFrom httr GET content
#' @importFrom purrr map_df map2_df
#' @import tibble
#' @import dplyr
#' @import tidyr
#' @return a data frame with the results of geocoding, with the SourceIndex column providing the index into the input address vector
#' @export
geocodeGoogle <- function(addresses, sleep=1.5, notificationFunction=emptyFunction, apiKey=NULL, ...) {
baseURL <- 'https://maps.googleapis.com/maps/api/geocode/json?'
if (!is.null(apiKey)) {
baseURL <- paste0(baseURL, 'key=', apiKey, '&')
}
baseURL <- paste0(baseURL, 'address=')
indices <- seq(length(addresses))
sel <- !grepl(x=trimws(addresses), pattern='^[0-9]+$')
indices <- indices[sel]
addresses <- addresses[sel]
map2_df(addresses, indices, function(address, index) {
url <- paste0(baseURL, URLencode(address))
getContent <- function() {
ret <- NULL
tryCatch({
ret <- fromJSON(url, simplifyDataFrame=FALSE)
}, error=function(e) {
writeLines(e$message)
})
ret
}
content <- NULL
tries <- 0
maxTries <- 10
errSleep <- 30
content <- getContent()
while (is.null(content) & tries < maxTries) {
writeLines(paste0('Error encountered, sleeping for ', errSleep, ' seconds...'))
Sys.sleep(errSleep)
writeLines('...resuming')
content <- getContent()
tries <- tries + 1
}
ret <- NULL
tryCatch({
if (length(content) > 1) {
results <- content$results
if (length(results) > 0) {
results <- results[[1]]
ac <- results$address_components
location <- results$geometry$location
types <- results$types
if (!is.null(ac)) {
addNAField <- function(df_, fieldName) {
if (!nrow(df_ %>% filter(field==fieldName))) {
df_ <- bind_rows(df_, tibble(field=fieldName, value=NA_character_))
}
df_
}
ret <- ac %>% map_df(function(ll) {tibble(field=ll$types, value=ll$short_name)}) %>%
filter(!(field %in% c('political')))
if (nrow(filter(ret, field %in% c('administrative_area_level_1', 'postal_code')))) {
isIntersection <- 'intersection' %in% types
ret <- ret %>%
addNAField('street_number') %>%
addNAField('route') %>%
addNAField('locality') %>%
addNAField('sublocality') %>%
addNAField('administrative_area_level_1') %>%
addNAField('postal_code') %>%
spread(key=field, value=value) %>%
mutate(locality=ifelse(is.na(locality), sublocality, locality)) %>%
select(Number=street_number, Street=route, City=locality, State=administrative_area_level_1, Zip=postal_code) %>%
mutate(Latitude=location$lat, Longitude=location$lng, Source='Google',
Approximate=(is.na(Number) & !isIntersection), InputAddress=address, SourceIndex=index)
}
}
}
Sys.sleep(sleep * (index < max(indices)))
}
}, error=function(e) {
print(e)
writeLines(paste0('Address causing error: ', address))
writeLines('Geocoding will continue...')
ret <- NULL
})
if (!is.null(ret)) {
if ('field' %in% colnames(ret)) {
ret <- select(ret, -field)
}
if ('value' %in% colnames(ret)) {
ret <- select(ret, -value)
}
}
notificationFunction(address, index, ret)
ret
}) %>% filter(!is.na(SourceIndex))
}
#' Create a notification function that logs a progress message every n addresses
#' @param n the frequency of notification
#' @export
createPeriodicNotificationFunction <- function(n) {
function(inputAddress, index, resultTibble) {
if(index %% n == 0) {
writeLines(paste0('Geocoded address # ', index))
}
invisible()
}
}
#' Default notification function that does nothing
#' @export
emptyFunction <- function(inputAddress, index, resultTibble) {invisible()}
scottcame/geocode documentation built on May 29, 2019, 4:07 p.m.
R Package Documentation
Browse R Packages
We want your feedback!
Note that we can't provide technical support on individual packages. You should contact the package authors for that.
# Copyright 2017 Scott Came Consulting LLC
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#' Geocode addresses using a hierarchy of geocoders, where later geocoders fill in gaps that earlier ones couldn't handle
#' @param geocoders the geocoders to try, in order
#' @param addresses the list of addresses to geocode
#' @param notificationFunction a function called after each geocode to enable logging, etc.
#' @param sleep number of seconds to sleep between requests (to avoid exceeding rate limits)
#' @param ... additional named arguments passed to specific geocoder functions
#' @import dplyr
#' @import tibble
#' @return a data frame with the results of geocoding, with the SourceIndex column providing the index into the input address vector
#' @export
geocode <- function(addresses, geocoders=c('Census', 'Nominatim', 'Google'), sleep=1.5, notificationFunction=emptyFunction, ...) {
ret <- tibble()
addresses <- trimws(addresses)
uniqueAddresses <- unique(addresses) %>% na.omit() %>% as.vector()
indices <- seq(length(uniqueAddresses))
names(indices) <- uniqueAddresses
missings <- uniqueAddresses
for (geocoder in geocoders) {
if (length(uniqueAddresses) > 0) {
f <- paste0('geocode', geocoder)
args <- list()
args$addresses <- missings
args$sleep <- sleep
args$notificationFunction <- notificationFunction
args <- c(args, list(...))
ret <- bind_rows(ret, do.call(f, args))
successes <- character()
if (nrow(ret)) {
successes <- ret$InputAddress
}
missings <- setdiff(uniqueAddresses, successes)
}
}
if (nrow(ret)) {
ret <- select(ret, -SourceIndex) %>%
right_join(tibble(InputAddress=addresses) %>% mutate(SourceIndex=row_number()), by='InputAddress') %>%
filter(!is.na(Source))
}
ret
}
#' Geocode addresses using an ArcGIS "findAddressCandidates" GeocodeServer service
#' @param addresses a vector of address strings
#' @param sleep number of seconds to sleep between requests (to avoid exceeding rate limits)
#' @param arcgisServiceURL base URL of the service address, up to and including the last forward slash preceding "findAddressCandidates?"
#' @param approximationThreshold the score value in the ArcGIS response below which a candidate is considered approximate
#' @param notificationFunction a function called after each geocode to enable logging, etc.
#' @param ... unused
#' @importFrom jsonlite fromJSON
#' @import dplyr
#' @import tibble
#' @importFrom purrr map2_df
#' @return a data frame with the results of geocoding, with the SourceIndex column providing the index into the input address vector
#' @export
geocodeArcGIS <- function(addresses, arcgisServiceURL='http://geocode.arcgis.com/arcgis/rest/services/World/GeocodeServer/', approximationThreshold=85,
sleep=1.5, notificationFunction=emptyFunction, ...) {
baseURL <- paste0(arcgisServiceURL, 'findAddressCandidates?singleLine=')
indices <- seq(length(addresses))
sel <- !grepl(x=trimws(addresses), pattern='^[0-9]+$')
indices <- indices[sel]
addresses <- addresses[sel]
map2_df(addresses, indices, function(address, index) {
url <- paste0(baseURL, URLencode(address), '&f=json&outFields=AddNum,StPreDir,StName,StType,StDir,City,Region,Postal,Addr_type')
content <- fromJSON(url, simplifyDataFrame=FALSE)
ret <- NULL
if (!is.null(content)) {
candidates <- content$candidates
if (length(candidates) > 0) {
candidate <- candidates[[1]]
street <- trimws(paste(candidate$attributes$StPreDir, candidate$attributes$StName, candidate$attributes$StType, candidate$attributes$StDir))
ret <- tibble(
Number=candidate$attributes$AddNum,
Street=street,
City=candidate$attributes$City,
State=candidate$attributes$Region,
Zip=candidate$attributes$Postal,
Latitude=candidate$location$y,
Longitude=candidate$location$x,
InputAddress=address,
Approximate=FALSE,
Source='ArcGIS',
SourceIndex=index,
Addr_type=candidate$attributes$Addr_type,
Score=candidate$score
) %>%
mutate_if(is.character, function(v) {ifelse(trimws(v)=='', NA_character_, v)}) %>%
mutate(accurate_=candidate$score >= approximationThreshold &
(Addr_type %in% c('StreetInt', 'POI') | (Addr_type %in% c('StreetName', 'PointAddress', 'StreetAddress') & !is.na(Number)))) %>%
mutate(Approximate=!accurate_) %>% select(-Addr_type, -accurate_, -Score)
}
}
Sys.sleep(sleep * (index < max(indices)))
notificationFunction(address, index, ret)
ret
})
}
#' Geocode addresses using the Census Geocoder
#' @param addresses a vector of address strings
#' @param sleep number of seconds to sleep between requests (to avoid exceeding rate limits)
#' @param notificationFunction a function called after each geocode to enable logging, etc.
#' @param ... unused
#' @importFrom jsonlite fromJSON
#' @import dplyr
#' @import tibble
#' @importFrom purrr map2_df
#' @return a data frame with the results of geocoding, with the SourceIndex column providing the index into the input address vector
#' @export
geocodeCensus <- function(addresses, sleep=1.5, notificationFunction=emptyFunction, ...) {
baseURL <- 'https://geocoding.geo.census.gov/geocoder/locations/onelineaddress?format=json&benchmark=Public_AR_Current&address='
indices <- seq(length(addresses))
sel <- !grepl(x=trimws(addresses), pattern='^[0-9]+$')
indices <- indices[sel]
addresses <- addresses[sel]
map2_df(addresses, indices, function(address, index) {
url <- paste0(baseURL, URLencode(address))
content <- fromJSON(url, simplifyDataFrame=FALSE)
ret <- NULL
if (!is.null(content)) {
result <- content$result
if (!is.null(result)) {
addressMatches <- result$addressMatches
if (length(addressMatches) > 0) {
matchComponents <- addressMatches[[1]]$addressComponents
coords <- addressMatches[[1]]$coordinates
ret <- tibble(
Number = paste0(matchComponents$fromAddress, '-', matchComponents$toAddress),
Street = gsub(x=trimws(paste0(matchComponents$preQualifier, ' ',
matchComponents$preDirection, ' ',
matchComponents$preType, ' ',
matchComponents$streetName, ' ',
matchComponents$suffixType, ' ',
matchComponents$suffixQualifier, ' ',
matchComponents$suffixDirection)),
pattern='[ ]+', replacement=' '),
City = matchComponents$city,
State = matchComponents$state,
Zip = matchComponents$zip,
Latitude=as.numeric(coords$y),
Longitude=as.numeric(coords$x),
InputAddress=address,
Approximate=(FALSE),
Source='Census',
SourceIndex=index
)
}
}
Sys.sleep(sleep * (index < max(indices)))
}
notificationFunction(address, index, ret)
ret
})
}
#' Geocode addreses using the Nominatim service provided by Open Street Map
#' @param addresses a vector of address strings
#' @param nominatimServiceURL the base address of the nominatim service to use; include everything that precedes the ?
#' @param sleep number of seconds to sleep between requests (to avoid exceeding rate limits)
#' @param notificationFunction a function called after each geocode to enable logging, etc.
#' @param ... unused
#' @importFrom jsonlite fromJSON
#' @import dplyr
#' @import tibble
#' @importFrom purrr map2_df
#' @return a data frame with the results of geocoding, with the SourceIndex column providing the index into the input address vector
#' @export
geocodeNominatim <- function(addresses, nominatimServiceURL='http://nominatim.openstreetmap.org', sleep=1.5, notificationFunction=emptyFunction, ...) {
baseURL <- paste0(nominatimServiceURL, '?addressdetails=1&format=json&q=')
indices <- seq(length(addresses))
sel <- !grepl(x=trimws(addresses), pattern='^[0-9]+$')
indices <- indices[sel]
addresses <- addresses[sel]
map2_df(addresses, indices, function(address, index) {
url <- paste0(baseURL, URLencode(address))
content <- fromJSON(url, simplifyDataFrame=FALSE)
ret <- NULL
if (length(content) > 0) {
j <- content[[1]]
ret <- tibble(
Number = ifelse(is.null(j$address$house_number), NA_character_, j$address$house_number),
Street = ifelse(is.null(j$address$road), NA_character_, j$address$road),
City = ifelse(is.null(j$address$city), NA_character_, j$address$city),
State = ifelse(is.null(j$address$state), NA_character_, j$address$state),
Zip = ifelse(is.null(j$address$postcode), NA_character_, j$address$postcode),
Latitude=as.numeric(j$lat),
Longitude=as.numeric(j$lon),
InputAddress=address,
Approximate=(is.null(j$address$house_number)),
Source='Nominatim',
SourceIndex=index
)
Sys.sleep(sleep * (index < max(indices)))
}
notificationFunction(address, index, ret)
ret
})
}
#' Geocode addreses using the Google geocoding API
#' @param addresses a vector of address strings
#' @param sleep number of seconds to sleep between requests (to avoid exceeding rate limits)
#' @param notificationFunction a function called after each geocode to enable logging, etc.
#' @param apiKey the Google API Key to use, or null (the default) to use no key
#' @param ... unused
#' @importFrom httr GET content
#' @importFrom purrr map_df map2_df
#' @import tibble
#' @import dplyr
#' @import tidyr
#' @return a data frame with the results of geocoding, with the SourceIndex column providing the index into the input address vector
#' @export
geocodeGoogle <- function(addresses, sleep=1.5, notificationFunction=emptyFunction, apiKey=NULL, ...) {
baseURL <- 'https://maps.googleapis.com/maps/api/geocode/json?'
if (!is.null(apiKey)) {
baseURL <- paste0(baseURL, 'key=', apiKey, '&')
}
baseURL <- paste0(baseURL, 'address=')
indices <- seq(length(addresses))
sel <- !grepl(x=trimws(addresses), pattern='^[0-9]+$')
indices <- indices[sel]
addresses <- addresses[sel]
map2_df(addresses, indices, function(address, index) {
url <- paste0(baseURL, URLencode(address))
getContent <- function() {
ret <- NULL
tryCatch({
ret <- fromJSON(url, simplifyDataFrame=FALSE)
}, error=function(e) {
writeLines(e$message)
})
ret
}
content <- NULL
tries <- 0
maxTries <- 10
errSleep <- 30
content <- getContent()
while (is.null(content) & tries < maxTries) {
writeLines(paste0('Error encountered, sleeping for ', errSleep, ' seconds...'))
Sys.sleep(errSleep)
writeLines('...resuming')
content <- getContent()
tries <- tries + 1
}
ret <- NULL
tryCatch({
if (length(content) > 1) {
results <- content$results
if (length(results) > 0) {
results <- results[[1]]
ac <- results$address_components
location <- results$geometry$location
types <- results$types
if (!is.null(ac)) {
addNAField <- function(df_, fieldName) {
if (!nrow(df_ %>% filter(field==fieldName))) {
df_ <- bind_rows(df_, tibble(field=fieldName, value=NA_character_))
}
df_
}
ret <- ac %>% map_df(function(ll) {tibble(field=ll$types, value=ll$short_name)}) %>%
filter(!(field %in% c('political')))
if (nrow(filter(ret, field %in% c('administrative_area_level_1', 'postal_code')))) {
isIntersection <- 'intersection' %in% types
ret <- ret %>%
addNAField('street_number') %>%
addNAField('route') %>%
addNAField('locality') %>%
addNAField('sublocality') %>%
addNAField('administrative_area_level_1') %>%
addNAField('postal_code') %>%
spread(key=field, value=value) %>%
mutate(locality=ifelse(is.na(locality), sublocality, locality)) %>%
select(Number=street_number, Street=route, City=locality, State=administrative_area_level_1, Zip=postal_code) %>%
mutate(Latitude=location$lat, Longitude=location$lng, Source='Google',
Approximate=(is.na(Number) & !isIntersection), InputAddress=address, SourceIndex=index)
}
}
}
Sys.sleep(sleep * (index < max(indices)))
}
}, error=function(e) {
print(e)
writeLines(paste0('Address causing error: ', address))
writeLines('Geocoding will continue...')
ret <- NULL
})
if (!is.null(ret)) {
if ('field' %in% colnames(ret)) {
ret <- select(ret, -field)
}
if ('value' %in% colnames(ret)) {
ret <- select(ret, -value)
}
}
notificationFunction(address, index, ret)
ret
}) %>% filter(!is.na(SourceIndex))
}
#' Create a notification function that logs a progress message every n addresses
#' @param n the frequency of notification
#' @export
createPeriodicNotificationFunction <- function(n) {
function(inputAddress, index, resultTibble) {
if(index %% n == 0) {
writeLines(paste0('Geocoded address # ', index))
}
invisible()
}
}
#' Default notification function that does nothing
#' @export
emptyFunction <- function(inputAddress, index, resultTibble) {invisible()}
R Package Documentation
Browse R Packages
We want your feedback!
Note that we can't provide technical support on individual packages. You should contact the package authors for that.
Embedding an R snippet on your website
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.