0

我刚刚遇到了这个强大的 R 包，但不幸的是，我无法找到如何并行解析响应为 JSON 的 url 列表。

作为一个简单的例子，假设我有一个城市列表（在瑞士）：

list_cities <- c("Winterthur", "Bern", "Basel", "Lausanne", "Lugano")

在下一步中，我想为每个列出的城市找到前往苏黎世市的公共交通连接。我可以使用以下传输 api 来查询公共时间表数据：

https://transport.opendata.ch

使用 httr 包，我可以为每个城市发出如下请求：

for (city in list_cities) {
   r <- GET(paste0("http://transport.opendata.ch/v1/connections?from=", city, "&to=Zurich&limit=1&fields[]=connections/duration"))
   cont <- content(r, as = "parsed", type = "application/json", encoding = "UTF-8")
}

获得个人旅程的持续时间。但是，我有更长的列表和更多的目的地。这就是为什么我正在寻找一种方法来并行发出多个请求。

4

1 回答 1

1

请注意，我没有对此进行测试-但首先，您将初始化并行工作程序

library(parallel)
cl <- makeCluster(detectCores() - 1)
clusterEvalQ(cl, { library(Rcrawler) }) # load required packages onto each parallel worker

使用您的相关命令发挥作用

custom_parse_json <- function(city) {
    r <- GET(paste0("http://transport.opendata.ch/v1/connections?from=", city, "&to=Zurich&limit=1&fields[]=connections/duration"))
    cont <- content(r, as = "parsed", type = "application/json", encoding = "UTF-8")
    return(cont)
}

导出功能到每个并行工作

clusterExport(cl, c("custom_parse_json"))

循环遍历城市列表

parLapply(cl, list_cities, function(i) custom_parse_json(i))

这应该会返回您的 JSON 内容列表。

于 2018-02-25T14:16:56.177 回答