我在RMongo上遇到了麻烦,所以我试图把我的工作转换成rmongodb。在这里中,我的查询在mongo控制台中如下所示:
db.final.find({},{"ids.myid":1,"org.name":1,"_id":0}).skip(0).limit(5000)在RMongo中是这样的:
dbGetQueryForKeys(db,'final', '{}','{"ids.myid":1,"org.name":1,"_id":0}',skip=0,limit=5000)(后者不是返回值,但Mongo控制台可以工作。)
我的理解是,在从文件中中,它应该是这样的:
library(rmongodb)
mcon <- mongo.create(host="myurl:port",db="dbname")
fields = mongo.bson.buffer.create()
mongo.bson.buffer.append(fields, "ids.myid", 1L)
mongo.bson.buffer.append(fields, "org.name", 1L)
mongo.bson.buffer.append(fields, "_id", 0L)
cur <- mongo.find(mcon,"final",fields=fields, limit=5000) # query takes the default null
df <- mongo.cursor.to.data.frame(cur)然而,我得到了:
data frame with 0 columns and 0 rows我的原始查询的正确翻译是什么?
我知道我的联系是有效的,因为:
mongo.get.databases(mcon)工作并显示正确的数据库。但是,我调用集合的方式可能有问题,因为
mongo.find.one(mcon,"final") 返回NULL。尽管db.final.findOne()工作得很好,但还是会这样!
发布于 2014-03-03 08:31:39
集合的命名空间(ns)是错误的。你的数据库的名字不见了。试试这个:
cur <- mongo.find(mcon,"dbname.final",fields=fields, limit=5000)和
mongo.find.one(mcon,"dbname.final")发布于 2014-03-03 13:47:12
我的缓冲区构造也出错了。
fields = mongo.bson.buffer.create()
mongo.bson.buffer.append(fields, "ids.myid", 1L)
mongo.bson.buffer.append(fields, "org.name", 1L)
mongo.bson.buffer.append(fields, "_id", 0L)应该是
buf = mongo.bson.buffer.create()
mongo.bson.buffer.append(buf, "ids.myid", 1L)
mongo.bson.buffer.append(buf, "org.name", 1L)
mongo.bson.buffer.append(buf, "_id", 0L)
fields <- mongo.bson.from.buffer(buf)通过文件。
https://stackoverflow.com/questions/22099484
复制相似问题