$map（聚合）

在此页面上

定义

兼容性
语法
示例
增加数组的每个元素
截断每个数组元素
将摄氏温度转换为华氏温度
了解详情

定义

$map: 对数组中的每个列项应用表达式，并返回包含已应用结果的数组。

兼容性

可以使用 $map 查找托管在以下环境中的部署：

MongoDB Atlas：用于云中 MongoDB 部署的完全托管服务

MongoDB Enterprise：基于订阅、自我管理的 MongoDB 版本
MongoDB Community：源代码可用、免费使用且可自行管理的 MongoDB 版本

语法

$map 表达式的语法如下：

{ $map: { input: <expression>, as: <string>, in: <expression> } }

字段	规范
`input`	解析为数组的表达式。如果 `input` 解析为 `null` 或指向缺失的字段，则 `$map` 返回 `null`。如果 `input` 解析为非数组、非 null 值，则管道将出错。
`as`	可选。代表 `input` 数组中每个元素的变量名称。如果未指定名称，则变量名称默认为`this`。
`in`	应用于 `input` 数组中每个元素的表达式。该表达式单独引用带有 `as` 中指定的变量名称的每个元素。

有关表达式的更多信息，请参阅表达式。

示例

增加数组的每个元素

在 mongosh 中创建名为 grades 的示例集合，其中包含以下文档：

db.grades.insertMany( [
  { quizzes: [ 5, 6, 7 ] },
  { quizzes: [ ] },
  { quizzes: [ 3, 8, 9 ] }
] )

下面的聚合操作将 $map 与 $add 表达式结合使用，使 quizzes 数组中的每个元素递增 2。

db.grades.aggregate( [
   {
      $project: {
         adjustedGrades: {
           $map: {
             input: "$quizzes",
             as: "grade",
             in: { $add: [ "$$grade", 2 ] }
           }
         }
      }
   }
 ] )

此操作返回以下结果：

[
  {
    _id: ObjectId("6390b8f7237da390c6869a62"),
    adjustedGrades: [ 7, 8, 9 ]
  },
  {
    _id: ObjectId("6390b8f7237da390c6869a63"),
    adjustedGrades: []
  },
  {
    _id: ObjectId("6390b8f7237da390c6869a64"),
    adjustedGrades: [ 5, 10, 11 ]
  }
]

截断每个数组元素

在 mongosh 中创建名为 deliveries 的示例集合，其中包含以下文档：

db.deliveries.insertMany( [
  {
    "city" : "Bakersfield",
    "distances" : [ 34.57, 81.96, 44.24 ]
  },
  {
    "city" : "Barstow",
    "distances" : [ 73.28, 9.67, 124.36 ]
  },
  {
    "city" : "San Bernadino",
    "distances" : [ 16.04, 3.25, 6.82 ]
  }
] )

以下聚合操作使用 $map 将 distances 数组中的每个元素 truncate 为其整数。

db.deliveries.aggregate( [
   {
      $project: {
         city: "$city",
         integerValues: {
            $map: {
               input: "$distances",
               as: "decimalValue",
               in: { $trunc: "$$decimalValue" }
            }
         }
      }
   }
 ] )

此操作返回以下结果：

[
  {
    _id: ObjectId("6390b9b1237da390c6869a65"),
    city: 'Bakersfield',
    integerValues: [ 34, 81, 44 ]
  },
  {
    _id: ObjectId("6390b9b1237da390c6869a66"),
    city: 'Barstow',
    integerValues: [ 73, 9, 124 ]
  },
  {
    _id: ObjectId("6390b9b1237da390c6869a67"),
    city: 'San Bernadino',
    integerValues: [ 16, 3, 6 ]
  }
]

将摄氏温度转换为华氏温度

在 mongosh 中创建名为 temperatures 的示例集合，其中包含以下文档：

db.temperatures.insertMany( [
  {
    "date" : ISODate("2019-06-23"),
    "tempsC" : [ 4, 12, 17 ]
  },
  {
    "date" : ISODate("2019-07-07"),
    "tempsC" : [ 14, 24, 11 ]
  },
  {
    "date" : ISODate("2019-10-30"),
    "tempsC" : [ 18, 6, 8 ]
  }
] )

以下聚合操作使用 $addFields 阶段向文档添加一个名为 tempsF 的新字段，其中包含 tempsC 数组中元素的华氏度等效值。为将摄氏温度转换为华氏温度，该操作使用 $map 将摄氏温度值先$multiply 9/5，再$add 32。

 db.temperatures.aggregate( [
   {
      $addFields: {
         "tempsF": {
            $map: {
               input: "$tempsC",
               as: "tempInCelsius",
               in: {
                  $add: [ { $multiply: [ "$$tempInCelsius", 9/5 ] }, 32 ]
               }
            }
          }
      }
    }
] )

此操作返回以下结果：

[
  {
    _id: ObjectId("6390ba11237da390c6869a68"),
    date: ISODate("2019-06-23T00:00:00.000Z"),
    tempsC: [ 4, 12, 17 ],
    tempsF: [ 39.2, 53.6, 62.6 ]
  },
  {
    _id: ObjectId("6390ba11237da390c6869a69"),
    date: ISODate("2019-07-07T00:00:00.000Z"),
    tempsC: [ 14, 24, 11 ],
    tempsF: [ 57.2, 75.2, 51.8 ]
  },
  {
    _id: ObjectId("6390ba11237da390c6869a6a"),
    date: ISODate("2019-10-30T00:00:00.000Z"),
    tempsC: [ 18, 6, 8 ],
    tempsF: [ 64.4, 42.8, 46.4 ]
  }
]

了解详情

要了解上述示例中所用表达式的更多信息，请参阅：

后退

$ltrim

来年

$max