MongoDB 集合可以通过使用聚合管道（aggregation pipeline）和变更流（change streams）来支持实时分析。
聚合管道（Aggregation Pipeline）： 聚合管道是 MongoDB 中用于数据处理和分析的强大工具。你可以使用聚合管道对集合中的文档进行各种操作，如过滤、投影、分组、排序、限制等。这些操作可以在数据写入时实时执行，从而实现对数据的实时分析。
例如，假设你有一个名为 orders 的集合，其中包含订单信息。你可以使用聚合管道来计算每个客户的总订单金额：
db.orders.aggregate([
{ $group: { _id: "$customerId", totalAmount: { $sum: "$amount" } } },
{ $sort: { totalAmount: -1 } }
]);
变更流（Change Streams）： 变更流是 MongoDB 4.0 引入的一项功能，允许你实时监控集合中的数据变更。你可以使用变更流来捕获插入、更新、删除等操作，并对这些变更进行实时处理和分析。
例如，你可以使用变更流来监控 orders 集合中的订单变更，并计算每个客户的订单数量：
const changeStream = db.orders.watch();
changeStream.on('change', next => {
if (next.operationType === 'insert') {
// 处理新订单
} else if (next.operationType === 'update') {
// 处理更新订单
} else if (next.operationType === 'delete') {
// 处理删除订单
}
});
通过结合使用聚合管道和变更流，你可以实现对 MongoDB 集合的实时分析。例如，你可以实时计算客户的总订单金额、平均订单金额、最近订单等指标，并根据这些指标触发相应的业务逻辑。
