9. JSONオブジェクトストレージ:集計

通常のクエリに加え、MongoDBのAggregationを使用することができます。 グルーピング、データの加算など、複雑な検索条件を指定することができます。

本ガイドでは、SDKからのAPI呼び出しの方法について説明します。

注釈

使用にあたって、演算子の制限や注意事項があります。 事前に 集計(Aggregation) を参照して下さい。

9.1. 集計条件の指定

集計に使用するデータは、商品の売り上げ情報を含むObjectがsalesバケットに保存済みとします。

説明のため、一部フィールドは省略しています。

# salesバケットのデータ
{
    {"date":"2018-01-01", "shop":"Tokyo", "item":"A", "number":1, "price":100 ... },
    {"date":"2018-01-02", "shop":"Osaka", "item":"B", "number":1, "price":75  ... },
    {"date":"2018-01-02", "shop":"Osaka", "item":"C", "number":1, "price":250 ... },
    {"date":"2018-01-03", "shop":"Tokyo", "item":"A", "number":2, "price":200 ... },
    {"date":"2018-01-04", "shop":"Tokyo", "item":"B", "number":2, "price":150 ... }
}

検索の条件は、JSONオブジェクトの配列として指定します。 以下の例では、"Tokyo"で販売された商品毎に、売り上げの合計を集計します。

pipeline = [
    { "$match": { "shop": "Tokyo" }},
    { "$group": {
        "_id": "$item",
        "total": { "$sum": "$price" }
        }
    }
]

一致条件を表す"$match"で、販売した"shopが"Tokyo"であるオブジェクトに絞り込みを行います。

その後、"$group"では、商品"item"毎に、売上"price"の和を"total"としてグルーピングします。 _idに指定したフィールドは、グループ識別用のキーとして扱われます。

9.2. 集計の実行

Aggregationを使用するためには、ObjectBucketのaggregate()を呼び出します。 引数にはpipelineを指定します。

bucket = baas.ObjectBucket(service, "sales")
results = bucket.aggregate(pipeline)

結果はJSON配列で返却されます。 "item A" 2件、"item B" 1件の売り上げが集計されます。

集計データのイメージは以下の通りです。

[
    {"_id": "A", "total": 300},
    {"_id": "B", "total": 150},
]

注釈

MongoDBのAggregationは多様な集計機能をサポートしています。 詳細は以下を参照下さい。

• 集計(Aggregation)
• MongoDB Aggregation