Aggregation med flera kriterier och summamatchning baserat på räknenyckeln

Eftersom det finns två samlingar måste vi använda

• $lookup att gå med i dragsamlingar. Här använde jag okorrelerat underfrågor
• Aggregeringen utförs i colA samlingar, men i lookup s pipeline vi utför aggregering på colB . $unwind hjälper till att destrukturera items . $match hjälper till att eliminera oönskad data (matchstadiet kräver $expr ).
• När vår anslutning har lyckats behöver vi bara räkna arrayen med $size
• $reduce hjälper till att summera arrayvärdet för size

Mongoskriptet ges nedan.

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"
            ]
          }
        }
      }
    }
  }
])

Arbetande Mongo lekplats