背景

最近做了几个规则逻辑。用到mongo查询比较多，就是查询交易信息跑既定规则筛选出交易商户，使用聚合管道进行统计和取出简单处理后的数据，用SQL代替业务代码逻辑的判断。

方法

MongoDB聚合使用aggregate，聚合管道采取自动向下子执行方式，基本语法格式：

db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION)