Mongo查询以查找在不同匹配元素之后没有匹配元素的位置

Question

我正在尝试使用以下文档查询 MongoDB 集合（我无法控制），这些文档用作每个作业定义的作业日志：

{
    "definition": ...,
    "jobs": [ // sequential
        {
            "time": ...,
            "result": "success"
        },
        {
            "time": ... (after previous),
            "result": "failure"
        }
        {
            "time": ...,
            "result": "running"
        }
    ]
}

我想查找最近完成作业运行失败的每个作业定义，其中“失败”和“成功”是仅有的两种“已完成”结果类型，但可能有任何我不知道的其他结果的数量。

到目前为止，我已经想出这个来找到所有失败的工作：

db.collection.find({jobs: {$elemMatch: {result: "failure"}}})

如果纯 mongo 无法做到这一点，我当然可以获取失败列表并以编程方式搜索过滤器以匹配我的特定要求。

编辑：

我只能使用 mongo 2.6。我可以忽略任何非失败和非成功结果，但在成功和失败结果之前、之后和中间可能有任意数量的结果。

Answer 1

这超出了基本的find() 查询。您需要使用聚合框架。

最有效的方法是在 MongoDB 3.2 或更高版本中，因为我们有 $slice 和 $arrayElemAt 可以在 $project 阶段使用索引 @987654337 获取数组中的最后一个元素@，但在这里你应该使用$arrayElemAt，因为它返回元素，而$slice 返回一个元素数组。此外，您需要使用$let 运算符来访问使用dot notation 的子文档中的“结果”字段。

管道中的第一个阶段必须是 $match 阶段。这减少了通过线路发送的数据量以及管道中使用的时间和内存。

管道中的最后一个阶段也是$match 阶段，您只选择那些符合您的条件的文档。

db.collection.aggregate([
    { "$match": { "jobs.result": "failure" } }, 
    { "$project": { 
        "definition": 1,
        "result": { 
            "$let": { 
                "vars": { "job": { "$arrayElemAt": [ "$jobs", -1 ] } },
                "in": "$$job.result" 
            } 
        } 
    }}, 
    { "$match": { "result": "failure" } } 
])

---

从 MongoDB 3.0 向后，您需要一种效率较低的不同方法，因为这意味着您 $unwind 匹配后的“jobs”数组和 $group _id 您的文档，使用 $last 累加器运算符获取数组中的最后一个元素。当然小组赛的$first操作符是用来保留“定义”字段值的。

在对文档进行分组后，您需要使用$redact 管道阶段，当条件为true 或@ 时，使用逻辑条件将最后一个“作业”与您的条件匹配的所有文档返回到$$KEEP 文档987654352@false。

最后一个阶段是$project，您可以在其中指定要包含在结果中的字段。这也减少了通过网络发送的数据量以及用于在客户端解码文档的时间和内存。

db.collection.aggregate([
    { "$match": { "jobs.result": "failure" } }, 
    { "$unwind": "$jobs" }, 
    { "$group": { 
        "_id": "$_id", 
        "job": { "$last": "$jobs" }, 
        "definition": { "$first": "$definition" } 
    }}, 
    { "$redact": { 
        "$cond": [ 
            { "$eq": [ "$job.result", "failure" ] }, 
            "$$KEEP", 
            "$$PRUNE" 
        ] 
    }}, 
    // optional stage
    { "$project": { 
        "definition": 1, 
        "result": "$job.result" 
    }} 
])

Answer 2

您可以为此使用聚合框架

  db.robert.aggregate([     
         {
            $project : {
                _id : 1,
                def : 1,
                jobs : { //filter only fields by OK/NOK
                    $filter : {
                        input : "$jobs",
                        as : "item",
                        cond : {
                            $or : [{
                                    $eq :
                                    [{
                                            $cmp : ["$$item.staus", "success"]
                                        }, 0]
                                }, {
                                    $eq : [{
                                            $cmp : ["$$item.staus", "failure"]
                                        }, 0]
                                }
                            ]

                        }

                    }
                }
            }
        },
        {
            $project : {
                _id : 1,
                def : 1,
                jobs : {
                    $slice : ["$jobs", 2]//take first two entries of array
                    // this could be also last two use -2
                }
            }
        }, {
            $match : {
                jobs : {
                    $size : 2 //eliminate nulls and only one entry in the array
                }
            }
        }, {
            $project : { // this is a kind of creating parameters for $match
                _id : 1,
                def : 1,
                firstShouldBeFalied : {
                    $slice : ["$jobs", 1]
                },
                secondShouldBeSuccess : {
                    $slice : ["$jobs", 1, 1]
                },
            }
        }, {
            $match : {

                $and : [{
                        "firstShouldBeFalied.staus" : "failure"
                    }, {
                        "secondShouldBeSuccess.staus" : "success"
                    },
                ]

            }
        },

    ])

欢迎任何 cmets！