MongoDB: использовать $ unwind в $ lookup pipe

Question

В настоящее время мне нужно выполнить запрос с MongoDB с использованием структуры агрегации.Вот схема моих документов, а также запрос, который я хочу сделать.

tools

{
    "_id": 1,
    "code": "TOOL_1",
    "label": "Tool 1",
    "items": [
        {
            "code_it": TOOL_1_TT_1,
            "label": "Tool TT 1",
            "value": 25.00
        },
        {
            "code_it": TOOL_1_TT_2,
            "label": "Tool TT 2",
            "value": 17.00
        },
        {
            "code_it": TOOL_1_TT_3,
            "label": "Tool TT 3",
            "value": 17.00
        },
    ]
}

results_tools

{
    "_id": 1,
    results: [
        {
            "code_it": "TOOL_TT_2",
            "owner": "person_A"
        },
        {
            "code_it": "TOOL_TT_3",
            "owner": "person_D"
        },
        {
            "code_it": "TOOL_TT_2",
            "owner": "person_C"
        },
    ]
}


db.results_tools.aggregate([

    { $unwind: "$results" },
    { 
        $lookup: {
            from: "tools",
            let: { res_cod_it: "$code_it" },
            pipeline: [
                { $unwind: "$items" },
                { 
                    $match: { 
                        $expr: { 
                            $eq: [ "$$res_cod_it", "$code_it" ] 
                        }
                    }
                }
            ],
            as: "item"
        }
    },
    {
        $project: {
            "owner": 1,
            "el.code": "code_it",
            "el.label": "item.label",
            "el.value": "item.label"
        }
    }

]);

Я хотел бы иметь возможность получить метку инструмента на основе результатов.Однако во время выполнения у меня возникает ошибка, поэтому мне интересно, возможно ли использование $ unwind в конвейере $ lookup.

Спасибо за ваш ответ.Laurent

Answer 1

Вы можете использовать ниже конвейера.Обратите внимание на использование точечной нотации для ссылки на поля массива.

db.results_tools.aggregate([
  {"$unwind":"$results"},
  {"$lookup":{
    "from":"tools",
    "let":{"res_cod_it":"$results.code_it"},
    "pipeline":[
      {"$unwind":"$items"},
      {"$match":{"$expr":{"$eq":["$$res_cod_it","$items.code_it"]}}}
    ],
    "as":"item"
  }},
  {"$unwind":"$item"},
  {"$project":{
    "owner":"$results.owner",
    "code":"$item.items.code_it",
    "label":"$item.items.label",
    "value":"$item.items.value"
  }}
])