// 1. 数据库数据
// {
// "items": { // 集合（表名）
// "data": [ // 数据
// {
// "_id": "1",
// "price": 10
// },
// {
// "_id": "2",
// "price": 50
// },
// {
// "_id": "3",
// "price": 20
// },
// {
// "_id": "4",
// "price": 80
// },
// {
// "_id": "5",
// "price": 200
// }
// ]
// }
// }
// 02. 聚合操作 limit
// 聚合阶段，限制输出到下一阶段的记录数。
'use strict';
const db = uniCloud.database();
const $ = db.command.aggregate;
exports.main = async(event, context) => {
let res = await db.collection('items').aggregate()
// 返回价格大于 20 的记录的最小的两个记录：
.match({
price: $.gt(20)
})
.sort({
price: 1,
})
.limit(2)
.end();
return res;
};
// 聚合之后的返回值
// {
// "affectedDocs": 2,
// "data": [{
// "_id": "2",
// "price": 50
// }, {
// "_id": "4",
// "price": 80
// }]
// }