# 聚合例子
# 数据集
假设有一个名为 books 的图书集合，其示例数据结构如下：
{
"_id": "xxxx-xxxx-xxxx",
"category": "novel",
"title": "title 1",
"author": "author 1",
"sales": 5000,
"monthlySales": [1000, 1500, 2500]
}
# 例：求各类图书的平均销量
采用 books 图书数据集作为示例。求各类图书的平均销量的操作等价于将图书按类别（category）分组，然后对每组的销量（sales）求平均值，最后返回类别和平均销量信息。
const db = wx.cloud.database()
const $ = db.command.aggregate
const result = await db.collection('books').aggregate()
.group({
// 按 category 字段分组
_id: '$category',
// 每组有一个 avgSales 字段，其值是组内所有记录的 sales 字段的平均值
avgSales: $.avg('$sales')
})
.end()
返回结果示例如下：
{
"list": [
{
_id: "novel", // 组名
sales: 1035, // 组平均销量
},
{
_id: "science", // 组名
sales: 350, // 组平均销量
}
]
}
用到的聚合流水线阶段：group
用到的聚合流水线操作符：avg
# 例：求各类图书的最高销量作者和最低销量作者及其销量
采用 books 图书数据集作为示例。一个作者在一个图书类目下可能有多本书，这个操作可以分阶段进行批处理：
- 第一阶段： 按 "图书类目 + 作者" 进行分组，求得每个作者在该图书类目下的多本书的总销量
- 第二阶段： 将上一个阶段得到的结果按总销量排倒序，求得各图书类目作者的总销量排序
- 第三阶段： 将上一个阶段得到的结果按类目分组，各组分别取组中第一项（销量最高）和最后一项（销量最低）的作者名和总销量，返回最终结果
const db = wx.cloud.database()
const $ = db.command.aggregate
const result = db.collection('books').aggregate()
.group({
_id: {
category: '$category',
author: '$author',
},
totalSales: $.sum('$sales')
})
.sort({
totalSales: -1,
})
.group({
_id: '$_id.category',
bestSellingAuthor: $.first('$_id.author'),
bestSellingAuthorTotalSales: $.first('$totalSales'),
worstSellingAuthor: $.last('$_id.author'),
worstSellingAuthorTotalSales: $.last('$totalSales'),
})
.end().then(console.log)
返回结果示例如下：
{
"list": [
{
"_id": "novel",
"bestSellingAuthor": "author 1",
"bestSellingAuthorTotalSales": 550,
"worstSellingAuthor": "author 2",
"worstSellingAuthorTotalSales": 1520
},
{
"_id": "science",
"bestSellingAuthor": "author 4",
"bestSellingAuthorTotalSales": 1050,
"worstSellingAuthor": "author 3",
"worstSellingAuthorTotalSales": 3000
}
]
}