0

我一直在使用包 Rmongo 从 MongoDB 中提取数据。

library(Rmongo)

mongo <- mongoDbConnect("cmdbData", host="XX-MONGODB-02", port=27017)
data_users <- dbGetQuery(mongo, 'computers', '{}')

拉取的数据如下所示：

             update_bol      key      cData
1            delete          NA       "{ \"name\" : \"name1\" , \"domain\" : \"xx.yy.dk\"}"
2            update          NA       "{ \"name\" : \"name2\" , \"domain\" : \"xx.yy.dk\"}"
3            update          NA       "{ \"name\" : \"name3\" , \"domain\" : \"xx.yy.dk\"}"
4            update          NA       "{ \"name\" : \"null\" , \"domain\" : \"xx.yy.dk\"}"
5            update          NA       "{ \"name\" : \"name5\" , \"domain\" : \"zz.yy.dk\"}"
6            delete          NA       "{ \"name\" : \"name6\" , \"domain\" : \"zz.yy.dk\"}"

可以使用以下方法手动重新创建数据框：

data.frame(update_bol = c("delete", "update", "update", "update", "update", "delete"),
       key = c(NA, NA, NA, NA, NA, NA), 
       cData = c("{ \"name\" : \"name1\" , \"domain\" : \"xx.yy.dk\"}", "{ \"name\" : \"name2\" , \"domain\" : \"xx.yy.dk\"}", "{ \"name\" : \"name3\" , \"domain\" : \"xx.yy.dk\"}", "{ \"name\" : \"null\" , \"domain\" : \"xx.yy.dk\"}", "{ \"name\" : \"name5\" , \"domain\" : \"zz.yy.dk\"}", "{ \"name\" : \"name6\" , \"domain\" : \"zz.yy.dk\"}"), stringsAsFactors = FALSE)

我想要这个输出：

             name       domain
1            name1      xx.yy.dk
2            name2      xx.yy.dk
3            name3      xx.yy.dk
4            NULL       xx.yy.dk
5            name5      zz.yy.dk
6            name6      zz.yy.dk

我试图进行更高级的查询以直接从 dbGetQuery 函数输出 cData 列，但我是 MongoDB 新手，似乎找不到合适的查询。

cData 的格式看起来像 JSON，所以我也尝试使用“jsonlite”包来提取列，但我也无法做到这一点。你有什么建议吗？

library(jsonlite)
library(tidyverse)

fromJSON(data_users$ciData[1]) %>% as.data.frame

Error in (function (..., row.names = NULL, check.rows = FALSE, check.names = TRUE,  : 
arguments imply differing number of rows: 1, 0
4

2 回答 2

1

这可能不是最好的方法，但它会让你继续前进。在这种方法中，我将您拥有的数据转换为所需的格式。

df<-data.frame(update_bol = c("delete", "update", "update", "update", "update", "delete"),
   key = c(NA, NA, NA, NA, NA, NA), 
   cData = c("{ \"name\" : \"name1\" , \"domain\" : \"xx.yy.dk\"}", "{ \"name\" : \"name2\" , \"domain\" : \"xx.yy.dk\"}", "{ \"name\" : \"name3\" , \"domain\" : \"xx.yy.dk\"}", "{ \"name\" : \"null\" , \"domain\" : \"xx.yy.dk\"}", "{ \"name\" : \"name5\" , \"domain\" : \"zz.yy.dk\"}", "{ \"name\" : \"name6\" , \"domain\" : \"zz.yy.dk\"}"), stringsAsFactors = FALSE)

clean<-function(x){
cleand_x<-gsub(pattern = '[\\{\\}\\"]',replacement = "",x = df$cData,fixed=F)
cleand_x<-strsplit(cleand_x,split = " ")
final<-sapply(cleand_x,function(t)
{
    c(name=t[[4]],domain=t[[8]])
},simplify = T)
return(as.data.frame(t(final)))
}

clean(df)

输出

name   domain
1 name1 xx.yy.dk
2 name2 xx.yy.dk
3 name3 xx.yy.dk
4 name4 xx.yy.dk 
5 name5 zz.yy.dk
6 name6 zz.yy.dk
于 2017-05-19T09:02:47.950 回答
1

我会推荐 mongolite 包而不是 RMongo。您可以使用 mongo 查询从 mongodb 中提取数据，并将其放入数据框中。如果您要查询包含数组的数据，您将需要使用 $unwind 并可能使用“flatten”（flatten 来自 jsonlite 包）。

于 2017-06-12T21:09:11.067 回答