MongoDB/PyMongo: ¿Cómo usar la notación de puntos en una función de Mapa?

Question

Estoy tratando de contar cuántos registros he localizado en cada código postal.
En mi MongoDB, el código postal está incrustado; usando notación de punto, está ubicado en a.res.z (a para dirección, res para residencial, z para zip). Por ejemplo, esto funciona muy bien:

db.NY.count({'a.res.z' : '14120'}) 

Pero cuando trato de la función de mapa (en Python, porque estoy usando PyMongo):

map = Code("function() {" 
      " emit(this.a.res.z, 1);" 
      "}") 

me sale este error cuando llamo mapreduce:

pymongo.errors.OperationFailure: db assertion failure, assertion: 'map invoke failed: JS Error: TypeError: this.a has no properties nofile_b:0', assertionCode: 9014 

La notación de puntos funciona en el nivel superior, por ejemplo un punto, pero no puedo hacer que funcione en las incrustaciones. ¿Cuál es el secreto?

Answer 1

Este error significa que al menos un objeto que está reduciendo el mapa le falta el campo res de su a. Ver:

> db.NY.find({}, {_id: 0})            
{ "a" : { "res" : { "z" : 10011 } }, "name" : "alice" } 
{ "a" : { "res" : { "z" : 10011 } }, "name" : "bob" } 
{ "a" : { "res" : { "z" : 10012 } }, "name" : "carol" } 
> m                  
function() { 
    emit(this.a.res.z, 1); 
} 
> r                  
function (key, values) { 
    var v = 0; 
    values.forEach(function (obj) {v += obj;}); 
    return v; 
} 
> db.runCommand({mapreduce: "NY", map: m, reduce: r, out: {inline: 1}}) 
{ 
    "results" : [ 
     { 
      "_id" : 10011, 
      "value" : 2 
     }, 
     { 
      "_id" : 10012, 
      "value" : 1 
     } 
    ], 
    "timeMillis" : 0, 
    "counts" : { 
     "input" : 3, 
     "emit" : 3, 
     "output" : 2 
    }, 
    "ok" : 1 
} 
> db.NY.insert({a: {}, name: "empty"})              
> db.runCommand({mapreduce: "NY", map: m, reduce: r, out: {inline: 1}}) 
{ 
    "assertion" : "map invoke failed: JS Error: TypeError: this.a.res has no properties nofile_b:1", 
    "assertionCode" : 9014, 
    "errmsg" : "db assertion failure", 
    "ok" : 0 
} 

Usted puede usar un argumento query para mapear-reducir a funcionar solamente en aquellos que tienen los campos que desee:

> db.runCommand({mapreduce: "NY", map: m, reduce: r, out: {inline: 1}, 
       query: {"a.res.z": {$exists: true}}}) 
{ 
    "results" : [ 
     { 
      "_id" : 10011, 
      "value" : 2 
     }, 
     { 
      "_id" : 10012, 
      "value" : 1 
     } 
    ], 
    "timeMillis" : 1, 
    "counts" : { 
     "input" : 3, 
     "emit" : 3, 
     "output" : 2 
    }, 
    "ok" : 1 
} 

Para utilizar el argumento query de PyMongo, se puede establecer como un argumento de palabra clave map_reduce(...)