尝试在 MongoDB MapReduce 调用中包含 Query

Question

我正在尝试创建一个非常基本的 map-reduce 示例，该示例还在 MapReduce api 调用中合并了一个查询。

我的收藏有很多格式如下：

{ "_id" : { "$binary" : "PdYV4WMTAEyYMQHXJZfzvA==", "$type" : "03" }, 
    "firstname" : "Matthew", 
    "surname" : "Chambers", 
    "email" : "" }

代码如下：

var map = @"
function() {
    emit(this.surname, { count : 22 });
}";
var reduce = @"
function(key, emitValues) {
    return { count : emitValues[0].count };
}";

List<BsonValue> contactIds = new List<BsonValue>();
contactIds.Add(new Guid("A04FC88D-7BF7-443D-B5C3-EB11EE2B36DF"));
contactIds.Add(new Guid("26B690B3-5ED7-47F4-A878-3906E28BBC58"));
MongoDB.Driver.Builders.QueryConditionList queryList = MongoDB.Driver.Builders.Query.In("_id", BsonArray.Create(contactIds));
//var mr = personCollection.MapReduce(map, reduce);// THIS WORKS!    
var mr = personCollection.MapReduce(queryList, map, reduce); // THIS FAILS

如果我没有在 MapReduce 调用中包含 queryList，这一切都有效。但是，如果我确实包含了 queryList，那么我会收到以下运行时错误：

命令'mapreduce'失败：db断言失败（响应：{“assertion”：“'out'必须是字符串或对象”，“assertionCode”：13606，“errmsg”：“db断言失败”， “好”：0}） 在 C:\work\10gen\mongodb\mongo-csharp-driver\Driver\Core\MongoDatabase.cs: MongoDB.Driver.MongoCollection.MapReduce 中的 MongoDB.Driver.MongoDatabase.RunCommandAs[TCommandResult](IMongoCommand 命令)：第 621 行( BsonJavaScript map, BsonJavaScript reduce, IMongoMapReduceOptions options) 在 C:\work\10gen\mongodb\mongo-csharp-driver\Driver\Core\MongoCollection.cs: MongoDB.Driver.MongoCollection.MapReduce(IMongoQuery 查询, BsonJavaScript map, BsonJavaScript reduce) 在 C:\work\10gen\mongodb\mongo-csharp-driver\Driver\Core\MongoCollection.cs:line 823 at HPSLucene.Models.Mongo.MapReduce() in C:\Inetpub\wwwroot\HPSLucene\HPSLucene \Models\Mongo.cs:第 158 行

有人知道问题出在哪里吗？非常感谢。

Answer 1

看起来它已将您的呼叫与您认为正在呼叫的不同重载相匹配

即您打算调用 (query, map, reduce) 重载，但实际上它正在调用 (map, reduce, options) 重载。这会给您错误，因为您的第三个参数不是有效的选项参数。

尝试使用以下重载：（查询、映射、归约、选项） 然后它就可以正常工作了，不会对使用什么感到困惑。

例如返回 M/R 内联的结果，而不是存储在集合中：

var mr = personCollection.MapReduce(queryList, map, reduce, 
                MapReduceOptions.SetOutput(MapReduceOutput.Inline));

Answer 2

顺便说一句，按照 AdaTheDev 的回答，这就是我最终得到的结果：

List<BsonValue> contactIds = new List<BsonValue>();
contactIds.Add(new Guid("A04FC88D-7BF7-443D-B5C3-EB11EE2B36DF"));
contactIds.Add(new Guid("26B690B3-5ED7-47F4-A878-3906E28BBC58"));
MongoDB.Driver.Builders.QueryConditionList queryList = MongoDB.Driver.Builders.Query.In("_id", BsonArray.Create(contactIds));
MongoDB.Driver.Builders.MapReduceOptionsBuilder builder=new MongoDB.Driver.Builders.MapReduceOptionsBuilder();
builder.SetOutput(MongoDB.Driver.Builders.MapReduceOutput.Inline);
var mr = personCollection.MapReduce(map, reduce, builder);

Answer 3

我创建了一个测试程序来重现这一点，看起来它实际上正在调用正确的 MapReduce 重载。但是您在驱动程序中遇到了错误。我为它创建了一个 JIRA 案例：

http://jira.mongodb.org/browse/CSHARP-193

您的最终版本很好。通过提供显式选项参数，您可以解决该错误。