MongoDB:使用 $in 进行编辑的聚合失败

Question

我在名为 cars 的 mongo 集合中有以下两个对象:

{vendor: "BMW",
model: "325i",
class: "coupe",
equipment: [
    {name: "airbag",
     cost: 120
    },
    {name: "led",
     cost: 170
    },
    {name: "abs",
     cost: 150
    }
 ]
}

{vendor: "Mercedes",
model: "C 250",
class: "coupe",
equipment: [
    {name: "airbag",
     cost: 180
    },
    {name: "esp",
     cost: 170
    },
    {name: "led",
     cost: 120
    }
 ]
}

我正在尝试新的聚合功能 redact Mongo 2.6 中引入 我想执行查询来获取带有过滤设备零件的汽车列表。 换句话说:给我所有轿跑车类型的汽车，只提供有关 LED 和 AIRBAG 设备的信息。

我尝试过这种聚合:

db.cars.aggregate(
    [
        {$match: {"class": "coupe"}},
        {$redact:
        {
            $cond:
            {
                if: { $in : ["$name", ["airbag", "led"]]},
                then: "$$DESCEND",
                else: "$$PRUNE"
            }
        }
        }
    ]
)

但这会导致以下错误:

assert: command failed: { "errmsg" : "exception: invalid operator '$in'", "code" : 15999, "ok" : 0 } : aggregate failed

我做错了什么？还有其他方法可以实现目标吗？

我希望从 Mongo 得到这个结果:

{vendor: "BMW",
model: "325i",
class: "coupe",
equipment: [
    {name: "airbag",
     cost: 120
    },
    {name: "led",
     cost: 170
    }
 ]
}

{vendor: "Mercedes",
model: "C 250",
class: "coupe",
equipment: [
    {name: "airbag",
     cost: 180
    },
    {name: "led",
     cost: 120
    }
 ]
}

关于如何实现这一目标有什么建议吗？

干杯， 拉尔夫

Answer 1

$redact对于这种情况，管道运算符(operator)确实不是您想要的。它想要做的是递归地“下降”文档结构并评估每个“级别”的条件以查看它将采取什么操作。

在您的情况下，文档的顶层没有“名称”字段来满足条件，因此整个文档被“修剪”。

您在过滤数组之后，在这种情况下您不想使用 $unwind和 $match ，那么您可以使用新的运算符，例如 $map :

db.cars.aggregate([
    { "$match": { "class": "coupe" }},
    { "$project": {
        "equipment": {
            "$setDifference": [
                { "$map": {
                    "input": "$equipment",
                    "as": "el",
                    "in": {
                        "$cond": [
                             { "$or": [
                                { "$eq": [ "$$el.name", "airbag" ] },
                                { "$eq": [ "$$el.name", "led" ] }
                             ]},
                             { "$cond": [ 1, "$$el", 0 ] },
                             false
                        ]
                    }
                }},
                [false]
            ]
        }
    }}
])

$map运算符处理数组并针对所有元素评估逻辑条件，在本例中是 $cond 内的元素。 。与 $in 相同，在这个意义上不是逻辑运算符，使用 $or ，这是聚合框架的逻辑运算符。

由于任何不满足条件的项目都会返回 false，因此您现在需要做的是“删除”所有 false 值。这得到了 $setDifference 的帮助。通过比较，这将做到这一点。

结果就是你想要的:

{
    "_id" : ObjectId("53b2725120edfc7d0df2f0b1"),
    "equipment" : [
            {
                    "name" : "airbag",
                    "cost" : 120
            },
            {
                    "name" : "led",
                    "cost" : 170
            }
    ]
}
{
    "_id" : ObjectId("53b2725120edfc7d0df2f0b2"),
    "equipment" : [
            {
                    "name" : "airbag",
                    "cost" : 180
            },
            {
                    "name" : "led",
                    "cost" : 120
            }
    ]
}

如果您真的想使用$redact，那么总会有这个人为的示例:

db.cars.aggregate([
    { "$match": { "class": "coupe" }},
    { "$redact": {
        "$cond": {
            "if": {
                "$or": [
                    { "$eq": [
                       { "$ifNull": ["$name", "airbag"] },
                       "airbag"  
                    ]},
                    { "$eq": [
                       { "$ifNull": ["$name", "led"] },
                       "led"  
                    ]},
                ]
            },
            "then": "$$DESCEND",
            "else": "$$PRUNE"
        }
    }}
])

因此，这基本上确保了如果该字段在下降时根本不存在，那么它将“人为”产生一个将匹配的字段，因此该级别不会被“修剪”。如果该字段确实存在，则使用找到的值，如果与条件不匹配，则它将被修剪。