MongoDBで時間ごとに$avgを使って集計する方法

MongoDBで時間ごとに$avgを使って集計する方法

MongoDBで集計処理を行うには、aggregate()メソッドを使用します。このメソッドを利用することで、コレクション内のデータに対して平均値や合計値などの集計を簡単に計算できます。本記事では、日付型フィールドから「時」を抽出し、時間単位で$avg演算子により平均値を求める手順を、サンプルコード付きで解説します。

1. サンプルコレクションの作成

まず、insertOne()メソッドでドキュメントを挿入し、コレクションを作成しましょう。

> db.demo544.insertOne({"DueTime":new ISODate("2020-01-10 12:10:20"),Amount:100});{
     "acknowledged" : true,
     "insertedId" : ObjectId("5e8e1f029e5f92834d7f05ce")
}
> db.demo544.insertOne({"DueTime":new ISODate("2020-01-12 12:00:00"),Amount:500});{
     "acknowledged" : true,
     "insertedId" : ObjectId("5e8e1f089e5f92834d7f05cf")
}
> db.demo544.insertOne({"DueTime":new ISODate("2020-01-12 12:10:20"),Amount:900});{
     "acknowledged" : true,
     "insertedId" : ObjectId("5e8e1f109e5f92834d7f05d0")
}

2. 登録したドキュメントの確認

find()メソッドを使えば、コレクション内のすべてのドキュメントを表示できます。

> db.demo544.find();

上記のコマンドを実行すると、次のような出力が得られます。

{ "_id" : ObjectId("5e8e1f029e5f92834d7f05ce"), "DueTime" : ISODate("2020-01-10T12:10:20Z"), "Amount" : 100 }
{ "_id" : ObjectId("5e8e1f089e5f92834d7f05cf"), "DueTime" : ISODate("2020-01-12T12:00:00Z"), "Amount" : 500 }
{ "_id" : ObjectId("5e8e1f109e5f92834d7f05d0"), "DueTime" : ISODate("2020-01-12T12:10:20Z"), "Amount" : 900 }

3. 時間ごとに$avgで集計するクエリ

以下が、「時」単位でグループ化し、Amountフィールドの平均値を求める集計クエリです。

> db.demo544.aggregate({ "$group": { "_id": { "$hour": "$DueTime" }, "Amount": { "$avg": "$Amount" } }})

実行すると、次のような結果が出力されます。

{ "_id" : 12, "Amount" : 500 }

4. クエリの仕組み

• $hour：日付フィールドから時(0〜23)を抽出します。
• $group：抽出した時の値をキーとして、ドキュメントをグループ化します。
• $avg：各グループ内のAmountフィールドの平均値を計算します。

今回のサンプルでは、3件すべてのドキュメントの時刻が「12時台」であるため、1つのグループにまとめられ、(100 + 500 + 900) ÷ 3 = 500という平均値が出力されています。

注意点：フィールド名の大文字・小文字

MongoDBのフィールド名は大文字・小文字が区別されます。「DueTime」というフィールドを参照する場合は、「$DueTime」と正確に一致させてください。誤って「$dueTime」のように記述すると、該当フィールドが存在しないものとみなされ、_idがnullになってすべてのドキュメントが同一グループに集約されてしまうため注意が必要です。