归约功能故障排除

在本页面

reduce函数是一种 JavaScript 函数，它在map-reduce操作期间将与特定键关联的所有值“还原”到单个对象。 reduce函数必须满足各种要求。本教程有助于验证reduce函数满足以下条件：

  • reduce函数必须返回* type *必须与map函数发出的value的类型“相同”的对象。

  • valuesArray中元素的 Sequences 不应影响reduce函数的输出。

  • reduce函数必须是幂等。

有关reduce函数的所有要求的列表，请参见mapReduce或mongo shell 帮助器方法db.collection.mapReduce()。

确认输出类型

您可以测试reduce函数返回的值与map函数发出的值的类型相同。

  • 定义一个带有参数keyCustId和valuesPrices的reduceFunction1函数。 valuesPrices是整数数组：
var reduceFunction1 = function(keyCustId, valuesPrices) {
                          return Array.sum(valuesPrices);
                      };
  • 定义一个整数 samples 数组：
var myTestValues = [ 5, 5, 10 ];
  • 用myTestValues调用reduceFunction1：
reduceFunction1('myKey', myTestValues);
  • 验证reduceFunction1返回的是整数：
20
  • 定义一个带有参数keySKU和valuesCountObjects的reduceFunction2函数。 valuesCountObjects是包含两个字段count和qty的文档数组：
var reduceFunction2 = function(keySKU, valuesCountObjects) {
                          reducedValue = { count: 0, qty: 0 };

                          for (var idx = 0; idx < valuesCountObjects.length; idx++) {
                              reducedValue.count += valuesCountObjects[idx].count;
                              reducedValue.qty += valuesCountObjects[idx].qty;
                          }

                          return reducedValue;
                      };
  • 定义文档 samples 数组：
var myTestObjects = [
                      { count: 1, qty: 5 },
                      { count: 2, qty: 10 },
                      { count: 3, qty: 15 }
                    ];
  • 用myTestObjects调用reduceFunction2：
reduceFunction2('myKey', myTestObjects);
  • 验证reduceFunction2返回的文档正好是count和qty字段：
{ "count" : 6, "qty" : 30 }

确保对 Map 值的 Sequences 不敏感

reduce函数将key和values数组作为其参数。您可以测试reduce函数的结果不取决于values数组中元素的 Sequences。

  • 定义一个 samplesvalues1数组和一个 samplesvalues2数组，只是数组元素的 Sequences 不同：
var values1 = [
                { count: 1, qty: 5 },
                { count: 2, qty: 10 },
                { count: 3, qty: 15 }
              ];

var values2 = [
                { count: 3, qty: 15 },
                { count: 1, qty: 5 },
                { count: 2, qty: 10 }
              ];
  • 定义一个带有参数keySKU和valuesCountObjects的reduceFunction2函数。 valuesCountObjects是包含两个字段count和qty的文档数组：
var reduceFunction2 = function(keySKU, valuesCountObjects) {
                          reducedValue = { count: 0, qty: 0 };

                          for (var idx = 0; idx < valuesCountObjects.length; idx++) {
                              reducedValue.count += valuesCountObjects[idx].count;
                              reducedValue.qty += valuesCountObjects[idx].qty;
                          }

                          return reducedValue;
                      };
  • 首先使用values1，然后使用values2调用reduceFunction2：
reduceFunction2('myKey', values1);
reduceFunction2('myKey', values2);
  • 验证reduceFunction2返回的结果相同：
{ "count" : 6, "qty" : 30 }

确保减少功能幂等

因为 map-reduce 操作可能会为同一键多次调用reduce，并且不会为工作集中的键的单个实例调用reduce，所以reduce函数必须返回与发出的值相同类型的值来自map函数。您可以测试reduce函数处理“减少”的值而不影响* final *值。

  • 定义一个带有参数keySKU和valuesCountObjects的reduceFunction2函数。 valuesCountObjects是包含两个字段count和qty的文档数组：
var reduceFunction2 = function(keySKU, valuesCountObjects) {
                          reducedValue = { count: 0, qty: 0 };

                          for (var idx = 0; idx < valuesCountObjects.length; idx++) {
                              reducedValue.count += valuesCountObjects[idx].count;
                              reducedValue.qty += valuesCountObjects[idx].qty;
                          }

                          return reducedValue;
                      };
  • 定义一个 samples 键：
var myKey = 'myKey';
  • 定义一个示例valuesIdempotent数组，其中包含一个元素，该元素是对reduceFunction2函数的调用：
var valuesIdempotent = [
                         { count: 1, qty: 5 },
                         { count: 2, qty: 10 },
                         reduceFunction2(myKey, [ { count:3, qty: 15 } ] )
                       ];
  • 定义一个示例values1数组，该数组合并传递给reduceFunction2的值：
var values1 = [
                { count: 1, qty: 5 },
                { count: 2, qty: 10 },
                { count: 3, qty: 15 }
              ];
  • 首先使用myKey和valuesIdempotent然后再使用myKey和values1调用reduceFunction2：
reduceFunction2(myKey, valuesIdempotent);
reduceFunction2(myKey, values1);
  • 验证reduceFunction2返回的结果相同：
{ "count" : 6, "qty" : 30 }