映射/减少 Couchbase 和 Couchbase 之间的差异云蚂蚁

Question

我一直在使用 Couchbase Server，现在只是尝试将本地数据库复制到 Cloudant，但是我的 map/reduce 函数对使用其关联项目构建一组唯一标签时得到了相互冲突的结果...

// map.js
function(doc) {
  if (doc.tags) {
    for(var t in doc.tags) {
      emit(doc.tags[t], doc._id);
    }
  }
}

// reduce.js
function(key,values,rereduce) {
  if (!rereduce) {
    var res=[];
    for(var v in values) {
      res.push(values[v]);
    }
    return res;
  } else {
    return values.length;
  }
}

在 Cloudbase 服务器中，返回 JSON 如下：

{"rows":[
{"key":"3d","value":["project1","project3","project8","project10"]},
{"key":"agents","value":["project2"]},
{"key":"fabrication","value":["project3","project5"]}
]}

这正是我想要的 &预期的。然而，在 Cloudant 副本上执行相同的查询会返回以下内容：

{"rows":[
{"key":"3d","value":4},
{"key":"agents","value":1},
{"key":"fabrication","value":2}
]}

因此，它以某种方式仅返回值数组的长度... 高度混乱&我很感谢一些 M&R 忍者的见解...;)

Answer 1

看起来这正是您所期望的归约函数的行为。关键部分是这样的：

else {
return values.length;
}

在Cloudant中，总是调用rereduce（因为reduce需要跨越多个分片）。在这种情况下，rereduce调用values.length，它只会返回数组的长度。

Answer 2

我更喜欢隐式减少/重新减少，而不是依赖于 rereduce 参数。

function(doc) { // map
  if (doc.tags) {
    for(var t in doc.tags) {
      emit(doc.tags[t], {id:doc._id, tag:doc.tags[t]});
    }
  }
}

然后reduce检查它是否从相同标签累积文档ID，或者是否只是计算不同的标签。

function(keys, vals, rereduce) {
  var initial_tag = vals[0].tag;

  return vals.reduce(function(state, val) {
    if(initial_tag && val.tag === initial_tag) {
      // Accumulate ids which produced this tag.
      var ids = state.ids;
      if(!ids)
        ids = [ state.id ]; // Build initial list from the state's id.
      return { tag: val.tag, 
             , ids: ids.concat([val.id])
             };
    } else {
      var state_count = state.ids ? state.ids.length : state;
      var val_count   = val.ids   ? val.ids.length   : val;
      return state_count + val_count;
    } 
  })
}

（我没有测试这段代码，但你明白了。只要tag值相同，无论是reduce还是rereduce都没关系一旦不同的标签开始一起减少，它就会检测到，因为 tag 值会发生变化，所以在那时我就开始积累

看来，它也很少值得。

这个技巧，尽管在我 strong>您的具体情况，这是一个危险的减少功能，如果您想查看所有文档，那么您正在构建一个宽列表来查看所有具有标签的文档。有标签，你可以映射它们

for(var a = 0; a < doc.tags.length; a++) {
  emit(doc.tags[a], doc._id);
}

现在你可以查询 /db/_design/app/_view/docs_by_tag?key="3d" 你应该得到

{"total_rows":287,"offset":30,"rows":[
{"id":"project1","key":"3d","value":"project1"}
{"id":"project3","key":"3d","value":"project3"}
{"id":"project8","key":"3d","value":"project8"}
{"id":"project10","key":"3d","value":"project10"}
]}