ネストされたクエリを使用したMongo$lookupフィルター

$match $lookup内 パイプラインはjobCollectionとは関係ありません ドキュメント。 tasksのドキュメントのみをフィルタリングします コレクション。したがって、もう1つ$matchを使用する必要があります $lookupの後のステージ ROOT（jobCollectionを除外します ）ドキュメント。

jobCollection.aggregate([
  { "$match": { "$text": { "$search": "1234" }}},
  { "$lookup": {
    "from": "task",
    "let": { "job_id": "$_id" },
    "pipeline": [
      { "$match": {
        "$expr": {
          "$and": [
            { "$eq": ["$job", "$$job_id"] },
            { "$eq": ["$status", "FAILED"] }
          ]
        }
      }}
    ],
    "as": "tasks"
  }},
  { "$match": { "tasks": { "$ne": [] }}},
])