mongo聚合操作符$unwind

1.原始数据

2.需求

1.按条件获取所有停机原因及对应的停机时长数据

2.按条件获取指定停机类型下的停机原因及停机时长

3.操作

3.1 获取所有停机原因及时长

db.stop_reason_duration_daily_data.aggregate([{'$match': {"timestamp": {"$gte": ISODate("2020-10-01T00:00:00.000+0000"), "$lt": ISODate("2020-12-24T00:00:00.000+0000")},}},{'$unwind': '$reason_detail_res'},{'$group': {'_id': '$reason_detail_res.name','count': {'$sum': '$reason_detail_res.value'},}},{'$project': {'_id': 0,'name': '$_id','value': '$count'}}])

3.2 指定停机分类或停机类型下的停机原因及时长

db.stop_reason_duration_daily_data.aggregate([{'$match': {"timestamp": {"$gte": ISODate("2020-10-01T00:00:00.000+0000"), "$lt": ISODate("2020-12-24T00:00:00.000+0000")},}},{'$unwind': '$reason_detail_res'},{'$match': {'reason_detail_res.reason_class': '速度损失', 'reason_detail_res.shut_down_type': '计划外停机'}},  # 此处用来过滤指定停机分类或停机类型{'$group': {'_id': '$reason_detail_res.name','count': {'$sum': '$reason_detail_res.value'},}},{'$project': {'_id': 0,'name': '$_id','value': '$count'}}])

4.$unwind 拆解数组字段

4.1 定义

定义 field版

{ $unwind: <field path> }

定义document版

{$unwind:{path: <field path>,includeArrayIndex: <string>,preserveNullAndEmptyArrays: <boolean>}
}

path 你要打散的字段
includeArrayIndex，可选的。一个新字段的名称，用于保存元素的数组索引。名称不能以美元符号开头。
preserveNullAndEmptyArrays，可选的。如果为true，则如果path为null，缺失或空数组，则$unwind输出文档。如果为false，如果path为null，缺少或为空数组，$unwind则不会输出文档。默认值为false。

4.2 示例:

原始数据

db.inventory.insertOne({ "_id" : 1, "item" : "ABC1", sizes: [ "S", "M", "L"] })

拆分数组

db.inventory.aggregate( [ { $unwind : "$sizes" } ] )

拆分结果

{ "_id" : 1, "item" : "ABC1", "sizes" : "S" }
{ "_id" : 1, "item" : "ABC1", "sizes" : "M" }
{ "_id" : 1, "item" : "ABC1", "sizes" : "L" }

参考：https://docs.mongodb.com/manual/reference/operator/aggregation/unwind/

mongo聚合操作符$unwind相关推荐

Mongo 聚合框架-Aggregate(一)
一概念 1.简介使用聚合框架可以对集合中的文档进行变换和组合.可以用多个构件创建一个管道,用于对一连串的文档进行处理.构件有:筛选.投射.分组.排序.限制和跳过. MongoDB的聚合管道将Mon ...
Mongo聚合函数使用Sort排序时内存不足导致查询失败,开启allowDiskUse=true
目录 1.问题描述 2.问题解决 1. Java代码方式解决办法 2. Mongo 原生聚合函数解决办法 1.问题描述由于项目原因, 需要向数据存储至mongo,在使用过程中 , 单个documen ...
【mongoDB实战】聚合管道--$unwind
$unwind:将文档中的某一个数组类型字段拆分成多条,每条包含数组中的一个值. 在做项目的时候碰上了这样的需求: 实例讲解: {"_id" : ObjectId(" ...
mongo java aggregate_java使用spring + mongo进行Aggregation聚合查询
笔记:使用mongo聚合查询(一开始根本没接触过mongo,一点一点慢慢的查资料完成了工作需求) 需求:在订单表中,根据buyerNick分组,统计每个buyerNick的电话.地址.支付总金额以及总 ...
mongodb聚合查询-aggregate
Mongodb-aggregate 在工作中经常遇到一些mongodb的聚合操作,和mysql对比起来,mongo存储的可以是复杂的类型,比如数组,字典等mysql不善于处理的文档型结构,但是mong ...
mongodb高级聚合查询
在工作中会经常遇到一些mongodb的聚合操作,特此总结下.mongo存储的可以是复杂类型,比如数组.对象等mysql不善于处理的文档型结构,并且聚合的操作也比mysql复杂很多. 注:本文基于 mo ...
MongoDB聚合查询 Pipeline 和 MapReduce
MongoDB聚合查询 MongoDB聚合查询什么是聚合查询 Pipeline聚合管道方法聚合流程详细流程聚合语法常用聚合管道 $count $group $match $unwind $p ...
mongodb-18.聚合查询练习1
文章目录 bulk write addFields 增加field 嵌套增加field 覆盖显示用变量替换向数组中增加元素分组 bucket 并行执行多个bucket $bucketAuto $ ...
mongodb aggregate $unwind
首先了解一下这个单词啥意思,知道的就不说了,不知道的咱先了解一下. 那么mongo的这个 $unwind 命令的作用:拆分(unwind)可以将数组中的每一个值拆分为单独的文档. 示范一下怎么拆分先 ...