0

サンプルの mongodb 集計コレクション (http://media.mongodb.org/zips.json) を使用して、カリフォルニア州のすべての都市の人口割合を出力したいと思います。

SQL では、次のようになります。

SELECT city, population/SUM(population) as poppct
FROM (
    SELECT city, SUM(population) as population
    FROM zipcodes
    WHERE state='CA'
    GROUP BY city
) agg group by state;

これは、mongodb map/reduce を使用して実行できます。

db.runCommand({
   mapreduce : "zipcodes"
   , out : { inline : 1}
   , query : {state: "CA"}
   , map : function() { 
       emit(this.city, this.pop); 
       cache.totalpop = cache.totalpop || 0; 
       cache.totalpop += this.pop; 
     }
   , reduce : function(key, values) {
       var pop = 0;
       values.forEach(function(value) {
          if (value && typeof value == 'number' && value > 0) pop += value;
       });
       return pop;
     }
   , finalize: function(key, reduced) {
       return reduced/cache.totalpop;
     }
   , scope: { cache: { } }
});

これは、新しい集計フレームワーク (v2.2) を使用しても実現できますか? これには、map/reduce の場合のように、何らかの形式のグローバル スコープが必要になります。

ありがとう。

4

2 に答える 2

0

これはあなたが求めているものですか？

db.zipcodes.remove();
db.zipcodes.insert([
    { city:"birmingham", population:1500000, state:"AL" },
    { city:"London", population:10000, state:"ON" },
    { city:"New York", population:1000, state:"NY" },
    { city:"Denver", population:100, state:"CO" },
    { city:"Los Angeles", population:1000000, state:"CA" },
    { city:"San Francisco", population:2000000, state:"CA" },
]);

db.zipcodes.runCommand("aggregate", { pipeline: [
    { $match: { state: "CA" } }, // WHERE state='CA'
    { $group: {
        _id: "$city",            // GROUP BY city
        population: { $sum: "$population" }, // SUM(population) as population
    }},
]});

生産する

{
    "result" : [
            {
                "_id" : "San Francisco",
                "population" : 2000000
            },
            {
                "_id" : "Los Angeles",
                "population" : 1000000
            }
    ],
    "ok" : 1
}
于 2012-10-30T08:37:20.310 に答える
0

あなたが試すことができます：

db.zipcodes.group( { key: { state:1 } , 
                  reduce: function(curr, result) { 
                              result.total += curr.pop; 
                              result.city.push( { _id: curr.city, pop: curr.pop } ); }, 
                 initial: { total: 0, city:[] }, 
                 finalize: function (result) {
                              for (var idx in result.city ) {
                                 result.city[idx].ratio = result.city[idx].pop/result.total;
                               } 

                              } } )
于 2012-10-30T19:49:20.140 に答える