$replaceWith (estágio de agregação )

Exemplo 1

Uma collection de exemplo sales é preenchida com os seguintes documentos:

db.sales.insertMany([
   { "_id" : 1, "item" : "butter", "price" : 10, "quantity": 2, date: ISODate("2019-03-01T08:00:00Z"), status: "C" },
   { "_id" : 2, "item" : "cream", "price" : 20, "quantity": 1, date: ISODate("2019-03-01T09:00:00Z"), status: "A" },
   { "_id" : 3, "item" : "jam", "price" : 5, "quantity": 10, date: ISODate("2019-03-15T09:00:00Z"), status: "C" },
   { "_id" : 4, "item" : "muffins", "price" : 5, "quantity": 10, date: ISODate("2019-03-15T09:00:00Z"), status: "C" }
])

Assume that for reporting purposes, you want to calculate for each completed sale, the total amount as of the current report run time. The following operation finds all the sales with status C and creates new documents using the $replaceWith stage. The $replaceWith calculates the total amount as well as uses the variable NOW to get the current time.

db.sales.aggregate([
   { $match: { status: "C" } },
   { $replaceWith: { _id: "$_id", item: "$item", amount: { $multiply: [ "$price", "$quantity"]}, status: "Complete", asofDate: "$$NOW" } }
])

A operação retorna os seguintes documentos:

[
  { _id: 1, item: 'butter', amount: 20, status: 'Complete', asofDate: '...' },
  { _id: 3, item: 'jam', amount: 50, status: 'Complete', asofDate: '...' },
  { _id: 4, item: 'muffins', amount: 50, status: 'Complete', asofDate: '...' }
]

Exemplo 2

Uma collection de exemplo reportedsales é preenchida com as informações de vendas relatadas por trimestre e regiões:

db.reportedsales.insertMany( [
   { _id: 1, quarter: "2019Q1", region: "A", qty: 400 },
   { _id: 2, quarter: "2019Q1", region: "B", qty: 550 },
   { _id: 3, quarter: "2019Q1", region: "C", qty: 1000 },
   { _id: 4, quarter: "2019Q2", region: "A", qty: 660 },
   { _id: 5, quarter: "2019Q2", region: "B", qty: 500 },
   { _id: 6, quarter: "2019Q2", region: "C", qty: 1200 }
] )

Suponha que, para fins de relatório, você queira visualizar os dados de vendas relatados por trimestre. Por exemplo

{ "_id" : "2019Q1", "A" : 400, "B" : 550, "C" : 1000 }

Para visualizar os dados agrupados por trimestre, você pode usar o seguinte aggregation pipeline:

db.reportedsales.aggregate( [
   { $addFields: { obj:  { k: "$region", v: "$qty" } } },
   { $group: { _id: "$quarter", items: { $push: "$obj" } } },
   { $project: { items2: { $concatArrays: [ [ { "k": "_id", "v": "$_id" } ], "$items" ] } } },
   { $replaceWith: { $arrayToObject: "$items2" } }
] )

Primeiro estágio:

O estágio $addFields adiciona um novo campo de documento obj que define a chave k como o valor da região e o valor v como a quantidade dessa região. Por exemplo:

{ "_id" : 1, "quarter" : "2019Q1", "region" : "A", "qty" : 400, "obj" : { "k" : "A", "v" : 400 } }

Segundo estágio:

O estágio $group agrupa por trimestre e usa $push para acumular os campos obj em um novo campo de array items. Por exemplo:

{ "_id" : "2019Q1", "items" : [ { "k" : "A", "v" : 400 }, { "k" : "B", "v" : 550 }, { "k" : "C", "v" : 1000 } ] }

Terceiro estágio:

O estágio $project usa $concatArrays para criar uma nova array items2 que inclui as informações _id e os elementos da array items:

{ "_id" : "2019Q1", "items2" : [ { "k" : "_id", "v" : "2019Q1" }, { "k" : "A", "v" : 400 }, { "k" : "B", "v" : 550 }, { "k" : "C", "v" : 1000 } ] }

Quarto estágio:

The $replaceWith uses the $arrayToObject to convert the items2 into a document, using the specified key k and value v pairs and outputs that document to the next stage. For example:

{ "_id" : "2019Q1", "A" : 400, "B" : 550, "C" : 1000 }

A aggregation retorna o seguinte documento:

[
  { _id: '2019Q1', A: 400, B: 550, C: 1000 },
  { _id: '2019Q2', A: 660, B: 500, C: 1200 }
]