Agregacja z wieloma kryteriami i dopasowaniem sum na podstawie klucza liczby

Ponieważ istnieją dwie kolekcje, musimy użyć

• $lookup dołączyć do zbiórek holowniczych. Tutaj użyłem nieskorelowane podzapytania
• Agregacja jest wykonywana w colA kolekcje, ale wewnątrz lookup pipeline wykonujemy agregację na colB . $unwind pomaga zdestrukturyzować items . $match pomaga wyeliminować niechciane dane (etap dopasowania wymaga $expr ).
• Gdy nasze połączenie się powiedzie, wystarczy policzyć tablicę za pomocą $size
• $reduce pomaga zsumować wartość tablicy size

Skrypt mongo jest podany poniżej.

db.colA.aggregate([
  {
    $lookup: {
      from: "colB",
      let: {
        bid: "$_id"
      },
      pipeline: [
        {
          $match: {
            $or: [
              {
                is_delete: false
              },
              {
                is_delete: {
                  "$exists": false
                }
              }
            ]
          }
        },
        {
          $unwind: "$items"
        },
        {
          $match: {
            $expr: {
              $eq: [
                "$items._id",
                "$$bid"
              ]
            }
          }
        },
        
      ],
      as: "data"
    }
  },
  {
    $project: {
      count: {
        $reduce: {
          input: "$data",
          initialValue: 0,
          in: {
            $add: [
              "$$value",
              "$$this.items.size"
            ]
          }
        }
      }
    }
  }
])

Praca Plac zabaw Mongo