チャートのレンダリングに必要なデータを取得するために、Charts は MongoDB Aggregation Pipeline を作成し、MongoDB database サーバー上でパイプラインを実行します。 パイプラインは複数のステージで構成されており、各ステージはチャートの作成者によって指定された異なる 設定 に基づいて生成されます。
このドキュメントでは、さまざまなチャートビルダの設定が集計パイプラインの構築にどのように使用されるかについて説明しています。 チャートの作成に使用されるパイプラインは、チャートビルダの右上にある省略記号ドロップダウンでView Aggregation Pipelineオプションを選択することで表示できます。
Atlas Charts では、次の順序で下記のセグメントで構成されるパイプラインが構築されます。
注意
チャートを作成するときは、前のチャート セグメントのすべてではなく、一部を構成できます。 Charts が集計パイプラインを生成するとき、指定されていないセグメントはスキップします。
例
次のチャートは、事務用品会社の合計売上額を購入方法別に分類したものです。 データコレクション内の各ドキュメントは 1 つの販売を表します。
このチャートを例として、上記の各設定の仕様によって、Atlas Charts によって生成される集計パイプラインがどのように変更されるかを調べます。
エンコーディング
Data Sourceパイプライン、 Queryバー クエリ、計算フィールド、フィルターがFilterペインに追加されていない場合、Atlas Charts は次の集計パイプラインを生成します。
{ "$addFields": { // Encoding "__alias_0": { "$sum": "$items.price" } }},{ "$group": { "_id": { "__alias_1": "$purchaseMethod" }, "__alias_0": { "$sum": "$__alias_0" } }},{ "$project": { "_id": 0, "__alias_1": "$_id.__alias_1", "__alias_0": 1 }},{ "$project": { "x": "$__alias_1", "y": "$__alias_0", "_id": 0 }},
{ "$addFields": { // Sorting "__agg_sum": { "$sum": [ "$y" ] } }},{ "$sort": { "__agg_sum": -1 }},{ "$project": { "__agg_sum": 0 }},{ "$limit": 5000}この時点でのパイプラインは、 Encodeパネル、デフォルトのソート順序のステージ、および Atlas Charts によって 5000 に設定されている最大ドキュメント数で構成されています。
クエリの追加
以下のクエリでは、表示されるドキュメントを、 saleDateがJanuary 1, 2017以降と等しく、かつitems配列に 5 つ以上の要素があるドキュメントのみに制限します。 itemsは、各要素が販売中に購入された商品である配列です。
クエリ:
{ $and: [ { saleDate: { $gte: new Date("2017-01-01") } }, { 'items.4': { $exists: true } } ]}上記のクエリをQueryバーで適用すると、次のチャートと集計パイプラインが生成されます。
集計パイプライン:
{ "$match": { // Query "$and": [ { "saleDate": { "$gte": { "$date": "2017-01-01T00:00:00Z" } } }, { "items.4": { "$exists": true } } ] }},{ "$addFields": { "__alias_0": { "$sum": "$items.price" } }},{ "$group": { "_id": { "__alias_1": "$purchaseMethod" }, "__alias_0": { "$sum": "$__alias_0" } }},{ "$project": { "_id": 0, "__alias_1": "$_id.__alias_1", "__alias_0": 1 }},{ "$project": { "x": "$__alias_1", "y": "$__alias_0", "_id": 0 }},{ "$addFields": { "__agg_sum": { "$sum": [ "$y" ] } }},{ "$sort": { "__agg_sum": -1 }},{ "$project": { "__agg_sum": 0 }},{ "$limit": 5000}集計パイプラインは、クエリが適用された状態で開始され、 Encodeパネルで選択されたグループと最大ドキュメント制限が続くようになりました。
計算フィールドの追加
また、 チャートを変更して、生成された総売上額を購入方法別に分類することもできます。 このタスクを実行するために、価格と数量を掛けて合計売上額を計算する計算フィールドを作成します。 上記のクエリに加えて、この新しい計算フィールドを追加すると、次のチャートとパイプラインが生成されます。
計算フィールド式:
集計パイプライン:
{ "$match": { "$and": [ { "saleDate": { "$gte": { "$date": "2017-01-01T00:00:00Z" } } }, { "items.4": { "$exists": true } } ] }},{ "$addFields": { // Calculated Field "revenue": { "$reduce": { "input": "$items", "initialValue": 0, "in": { "$sum": [ "$$value", { "$multiply": [ "$$this.price", "$$this.quantity" ] } ] } } } }},{ "$group": { "_id": { "__alias_0": "$purchaseMethod" }, "__alias_1": { "$sum": "$revenue" } }},{ "$project": { "_id": 0, "__alias_0": "$_id.__alias_0", "__alias_1": 1 }},{ "$project": { "x": "$__alias_0", "y": "$__alias_1", "_id": 0 }},{ "$addFields": { "__agg_sum": { "$sum": [ "$y" ] } }},{ "$sort": { "__agg_sum": -1 }},{ "$project": { "__agg_sum": 0 }},{ "$limit": 5000}更新されたパイプラインには、 Queryバーに適用されるクエリの直下に 計算フィールドが含まれるようになりましたが、コンポーネントの残りの順序は変更されません。
フィルターの追加
このチャートをさらに絞り込むには、 Filterペインにフィルターを追加して、ニューヨークのロケーションで行われた店舗内販売のみを選択します。 このフィルターを追加すると、次のチャートと集計パイプラインが生成されます。
集計パイプライン:
{ "$match": { "$and": [ { "saleDate": { "$gte": { "$date": "2017-01-01T00:00:00Z" } } }, { "items.4": { "$exists": true } } ] }},{ "$addFields": { "revenue": { "$reduce": { "input": "$items", "initialValue": 0, "in": { "$sum": [ "$$value", { "$multiply": [ "$$this.price", "$$this.quantity" ] } ] } } } }},{ "$match": { // Filter "storeLocation": { "$in": [ "New York" ] } }},{ "$group": { "_id": { "__alias_0": "$purchaseMethod" }, "__alias_1": { "$sum": "$revenue" } }},{ "$project": { "_id": 0, "__alias_0": "$_id.__alias_0", "__alias_1": 1 }},{ "$project": { "x": "$__alias_0", "y": "$__alias_1", "_id": 0 }},{ "$addFields": { "__agg_sum": { "$sum": [ "$y" ] } }},{ "$sort": { "__agg_sum": -1 }},{ "$project": { "__agg_sum": 0 }},{ "$limit": 5000}パイプラインには、計算フィールドの直下にstoreLocationフィルターが含まれるようになりましたが、コンポーネントの残りの順序は変更されません。