管道聚合各階段
創(chuàng)新互聯(lián)專(zhuān)注于全州企業(yè)網(wǎng)站建設(shè),成都響應(yīng)式網(wǎng)站建設(shè)公司,商城開(kāi)發(fā)。全州網(wǎng)站建設(shè)公司,為全州等地區(qū)提供建站服務(wù)。全流程按需搭建網(wǎng)站,專(zhuān)業(yè)設(shè)計(jì),全程項(xiàng)目跟蹤,創(chuàng)新互聯(lián)專(zhuān)業(yè)和態(tài)度為您提供的服務(wù)
名稱(chēng) | 描述 |
$project | 改造流中的文檔,像通過(guò)增加新的字段或移除存在的字段。對(duì)于每一個(gè)輸入文檔,輸出一個(gè)文檔。 |
$match | 過(guò)濾文檔流,只允許匹配的文檔不經(jīng)過(guò)修改進(jìn)入到下一個(gè)管道階段。$match使用標(biāo)準(zhǔn)的MongoDB查詢(xún)。對(duì)于每個(gè)輸入文檔,輸出要么一個(gè)文檔(匹配一個(gè))要么零個(gè)文檔(無(wú)匹配)。 |
$redact | 通過(guò)限制文檔的內(nèi)容(基于存儲(chǔ)于文檔它們自己的信息),改造流中每個(gè)文檔。結(jié)合$project和$match的功能??捎糜趯?shí)施字段級(jí)別的校訂。對(duì)于每個(gè)輸入文檔,輸出要么一個(gè)要么另個(gè)文檔。 |
$limit | 當(dāng)n指定值時(shí),傳遞前n個(gè)文檔不經(jīng)修改給管道。對(duì)于每個(gè)輸入文檔,輸出要么一個(gè)文檔(對(duì)于前n個(gè)文檔)要么零個(gè)文檔(在前n個(gè)文檔之后)。 |
$skip | 當(dāng)n指定為跳過(guò)數(shù)量時(shí),跳過(guò)前n個(gè)文檔,并傳遞剩下的文檔不經(jīng)過(guò)修改給管道。對(duì)于每一個(gè)輸入文檔,輸出要么零個(gè)文檔(對(duì)于前n個(gè)文檔)要么一個(gè)文檔(如果在前n個(gè)文檔之后)。 |
$unwind | 對(duì)于每一個(gè)元素,從輸入文檔解構(gòu)數(shù)組字段輸出一個(gè)文檔。每個(gè)輸出文檔使用元素值替換數(shù)組。對(duì)于每個(gè)輸入文檔,當(dāng)n為數(shù)組元素個(gè)數(shù),輸出n個(gè)文檔,對(duì)于空數(shù)組可以為零。 |
$group | 通過(guò)指定標(biāo)識(shí)符表達(dá)式分組輸入的文檔,并應(yīng)用累加器表達(dá)式,如果指定,到每個(gè)分組。遍歷所有的輸入文檔,對(duì)于每個(gè)不同的分組輸出一個(gè)文檔。輸出文檔只包含標(biāo)識(shí)符列和計(jì)算列(如果指定)。 |
$sort | 通過(guò)指定的排序鍵重排文檔流。只有順序改變了;文檔保持不變。對(duì)于每個(gè)輸入文檔,輸出一個(gè)文檔。 |
$geoUear | 返回一個(gè)排序的基于臨近一個(gè)地理空間點(diǎn)的文檔流。對(duì)于地理空間數(shù)據(jù),結(jié)合$match、$sort和$limit功能。輸出文檔包含額外的距離字段,并可以包含一個(gè)位置標(biāo)識(shí)符字段。 |
$out | 寫(xiě)聚合管道的結(jié)果文檔到一個(gè)集合。在使用$out階段,它必需是管道中的最后一個(gè)階段。 |
額外資源
MongoDB Analytics: Learn Aggregation by Example: Exploratory Analytics and Visualization Using Flight Data
MongoDB for Time Series Data: Analyzing Time Series Data Using the Aggregation Framework and Hadoop
The Aggregation Framework
Webinar: Exploring the Aggregation Framework
Quick Reference Cards