聚合管道生成器

指定自定义排序规则¶

使用自定义排序规则来指定特定于语言的字符串比较规则，例如字母大小写和重音符号规则。

要指定自定义排序规则：

1. 单击管道构建器顶部的“ 整理”按钮。
2. 输入您的整理文件。

局限性¶

$out如果您连接到Data Lake，则该舞台不可用 。

管道设置¶

要查看和修改管道设置：

1. 单击管道生成器右上方的齿轮图标，以打开“ 设置”面板。

2. 修改管道设置。可以修改以下设置：

   选项	描述	默认
   Comment Mode¶	启用后，将帮助程序注释添加到每个阶段。	已启用
   Number of Preview Documents¶	要在预览中显示的文档数。	20
   Max Time¶	处理管道的累积时间限制（以毫秒为单位）。使用此选项可以防止长时间挂起。	5000
   Limit¶	当采样模式启动，文件号传递给$group，$bucket和 $bucketAuto阶段。较低的限制会缩短管道执行时间，但可能会丢失文档。	100000

3. 单击“ 应用”保存更改并关闭“ 设置”面板。

创建管道¶

以下管道具有两个聚合阶段： $group和$match。

• 该$group阶段按其active状态和分组文档 country。该阶段还添加了一个名为flightCount每个组中包含文档数的新字段。
• 该$match阶段过滤文档以仅返回flightCount值大于或等于的文档5。

将管道复制到剪贴板上¶

1. 单击管道构建器顶部的“ 导出为语言”按钮。该按钮将打开以下模式：

   

2. 单击 左侧“ 我的管道”面板中的“ 复制”按钮。此按钮使用shell语法将管道复制到剪贴板。您将在以下部分中使用管道。mongo

执行流水线¶

1. 启动并连接到包含导入的数据集的 mongod实例air_airlines.json。

2. 切换到 集合所在的example数据库air_airlines：

   复制

   use example
   

3. 运行以下命令以执行在Compass中创建的管道：

   复制

   db.air_airlines.aggregate([{
     $group: {
       _id: {
         active: '$active',
         country: '$country'
       },
       flightCount: {
         $sum: 1
       }
     }
   }, {
     $match: {
       flightCount: {
         $gte: 5
       }
     }
   }])
   

以下是管道返回的文档的摘录：

{ "_id" : { "active" : "Y", "country" : "Nigeria" }, "flightCount" : 5 }
{ "_id" : { "active" : "N", "country" : "Switzerland" }, "flightCount" : 46 }
{ "_id" : { "active" : "N", "country" : "Bahrain" }, "flightCount" : 8 }
{ "_id" : { "active" : "N", "country" : "Guinea-Bissau" }, "flightCount" : 8 }
{ "_id" : { "active" : "N", "country" : "Argentina" }, "flightCount" : 14 }
{ "_id" : { "active" : "N", "country" : "Moldova" }, "flightCount" : 17 }
{ "_id" : { "active" : "Y", "country" : "Israel" }, "flightCount" : 6 }
{ "_id" : { "active" : "N", "country" : "Finland" }, "flightCount" : 7 }