Mongodb aggregate聚合语法按条件分组

Mongodb简介
MongoDB是一个基于分布式文件存储的数据库。由C++语言编写。旨在为WEB应用提供可扩展的高性能数据存储解决方案。

aggregate语法
Mongodb的Collection对象提供了aggregate()方法来对数据进行聚合处理。语法格式为：
aggregate(operators,[options],callback)

管道操作符

表达式操作符

业务需求
查询2021-10-01 到 2022-11-03，通话时间大于等於30秒的通话数量，按照打电话的人进行分组并统计组内数量

定义查询语句

db.getCollection('conversation_info').aggregate([
    {$match:{"connectMode":"tel","mediaType":"voice",
    "$and":[{"createTime":{"$gte":new Date("2021-10-01 00:00:00")}},{"createTime":{"$lt":new Date("2022-11-03 00:00:00")}}],
    "billSec":{$gte:NumberLong(30)}}},
    {$group:{"_id":'$senderId',counter:{$sum:1}}}
])
1
2
3
4
5
6

执行结果：