wie die Berechnung des Durchschnitts mit mongodb und NumberLong

Ich versuche, berechnen einen Mittelwert, der aus einer Sammlung über den mongodb-java-Treiber, wie hier:

DBObject condition = 
    new BasicDBObject("pluginIdentifier", plugin.getIdentifier());

DBObject initial = new BasicDBObject();

initial.put("count", 0);
initial.put("totalDuration", 0);
String reduce = "function(duration, out) { out.count++; 
    out.totalDuration+=duration.floatApprox; }";
String finalize = "function(out) { out.avg = out.totalDuration.floatApprox /
    out.count; }";

DBObject avg = durationEntries.group(
    new BasicDBObject("pluginIdentifier", true), 
    condition, initial, reduce, finalize);

System.out.println(avg);

"Dauer" ist ein NumberLong (in java, es ist eine Lange, wahrscheinlich die java-Treiber-konvertiert).
Ich fand nach etwas suchen, dass, um zu extrahieren, die Anzahl, mit .floatApprox war, einen Weg zu gehen, und das funktioniert auch in die mongodb-Konsole:

> db.DurationEntries.findOne().duration.floatApprox
5

Jedoch mit den obigen java-code nicht berechnen Durchschnitt, gibt aber statt

[{"pluginIdentifier":"dummy", "count":7.0, "totalDuration":NaN, "avg":NaN}]

Ich habe versucht, verschiedene Variationen, mit und ohne .floatApprox, aber nur in der Lage gewesen, um einige seltsame string-Verkettungen, bis jetzt.

Meine Frage ist: was mache ich falsch /wie gehe ich bei der Berechnung der durchschnittlichen von einem NumberLong Spalte?

  • Ist der Schlüssel hier, dass Sie wollen mongo tun die Mittelung anstatt ziehen der Spalte Daten in Java? Sind Sie sicher, dass Sie nicht versehentlich alle nicht-numerischen Daten zwischen Ihren Laufzeiten?
  • Ja, das ist meine Absicht, zu tun, die Berechnung in die Datenbank, anstatt im Speicher (weil wenn ich ' ll haben eine Menge Einträge, ich denke, dass meine JVM ausgeführt wird out-of-memory). Und ja, in der Tat kann es nicht-numerische Daten, soweit könnte es sein, "null" Durchschnitt Einträge - ich werde schauen, dass
  • Wenn alles, was Sie wollen, ist ein Durchschnitt, dann sollte es nicht nehmen große Mengen an Speicher, ich glaube, da brauchen Sie nicht zu halten, jeder Eintrag im Speicher, nur eine Summe und eine Zählung. Ich bin nicht vertraut genug mit Mongo zu sagen genau wie, aber wenn Sie können batch-das Ergebnis der Abfrage dann könnte Ihnen der Prozess einer Teilmenge zu einer Zeit.
InformationsquelleAutor Manuel Bernhardt | 2011-01-27
  1. 6

    Wenn Sie Probleme mit map/reduce, sollten Sie wahrscheinlich drop-down in der mongodb-Konsole, arbeiten es raus und dann übersetzen Sie das in Ihre Treiber.

    Nehmen Sie zum Beispiel die folgenden Dokumente:

    db.tasks.find()
{ "_id" : ObjectId("4dd51c0a3f42cc01ab0e6506"), "duration" : 10, "name" : "StartProcess", "date" : "20110501" }
{ "_id" : ObjectId("4dd51c0e3f42cc01ab0e6507"), "duration" : 11, "name" : "StartProcess", "date" : "20110502" }
{ "_id" : ObjectId("4dd51c113f42cc01ab0e6508"), "duration" : 12, "name" : "StartProcess", "date" : "20110503" }

    Schreiben Sie die mapReduce-Berechnung der durchschnittlichen Dauer von StartProcess wie folgt:

    m = function (){
  emit( this.name , { totalDuration : this.duration , num : 1 } );
};

r = function (name, values){
  var n = {totalDuration : 0, num : 0};
  for ( var i=0; i<values.length; i++ ){
    n.totalDuration += values[i].totalDuration;
    n.num += values[i].num;
  }
  return n;
};

f = function(who, res){
  res.avg = res.totalDuration / res.num;
  return res;
};

    Dann, wenn Sie mit MongoDB 1.7 oder höher:

    db.tasks.mapReduce( m, r, { finalize : f, out : {inline : 1} });

    Geben würde, Ihnen die folgende Antwort:

    "results" : [
  {
    "_id" : "StartProcess",
      "value" : {
        "totalDuration" : 33,
        "num" : 3,
        "avg" : 11
      }
  }
]

    Wenn das nicht hilft, können Sie Ihre map-Funktion und die Struktur der Dokumente.

    • danke! hatte endlich die Zeit, um zu gehen zurück zu diesem code und probieren Sie es aus!
    InformationsquelleAutor Leonard Garvey
Schreibe einen Kommentar