复合键的 $max 评估

Question

聚合框架的$max 运算符如何评估复合键。例如：

{
  $project: { 
    user: 1, 
    record: { date: "$upload_date", comment: 1, some_integer: 1 }
  }
},
{
  $group: {
    _id: "$user",
    latest: { $max : "$record" }
  }
}

它会通过date、comment 或some_integer 获得最大值吗？我只是假设它将通过date 获得最新消息。如果错了，找到date最大值的正确方法是什么？

编辑

从我到目前为止的尝试来看，最新的记录是由第一个键确定的。这是正确的行为吗？

编辑

为了了解我的用例，我有以下文档：

  > db.logs.findOne()
  {
  'id': ObjectId("50ad8d451d41c8fc58000003")
  'name': 'Sample Log 1',
  'uploaded_at': ISODate("2013-03-14T01:00:00+01:00"),
  'case_id': '50ad8d451d41c8fc58000099',
  'result': 'passing'
  'tag': ['TAG-XYZ']
  }

我有以下聚合：

  db.test_case_logs.aggregate(
  {$project: {tag:'$tag', case:'$case_id',
    latest: {upload_date:1, date:'$upload_date', result:'$result',
    passing : { $cond : [ { $eq : ["$result","passing"] }, 1, 0 ] },
    failing : { $cond : [ { $eq : ["$result","failing"] }, 1, 0 ] }}
  }},
  {$unwind: '$tag'},
  {$group: {_id:{tag:'$tag',case:'$case'}, latest:{$max:'$latest'}}},
  {$group: {_id:'$_id.tag',total:{$sum:1}, passing:{$sum:{$latest.passing}},
    failing:{$sum:{$latest.failing}, date:{$max:{$latest.upload_date}}}
  },
  {'$sort': {'date':-1}}
  )

日志可以具有相同的名称tag 和case_id，并且在分组两次之后，我需要结果是每个upload_date 对于每个tag 的最新日志。

编辑

我的预期结果是这样的：

  {
    '_id':'TAG-XYZ',
    'total':'1'
    'passing':'1'
    'failing':'0'
  }

每个计数对应给定案例的最新日志。

Answer 1

根据$max documentation，此运算符

返回该组选择的所有文档中该字段的所有值中的最大值。

您可以通过 { $max : "$record.date" }

指定日期的最大操作

聚合操作是这样的：

db.collection.aggregate ([
    { $project: { 
        user: 1, 
        record: { date: "$upload_date", comment: 1, some_integer: 1 }
    }},
    { $group: {
        _id: "$user",
        latest: { $max : "$record.date" }
    }}
])

Answer 2

对于您的情况，您可以使用$sort 运算符按$uploaded_at 字段对所有日志进行排序，并按标签和case_id 对排序结果进行分组，然后使用$first 运算符获取每个日志的第一项团体。

db.logs.aggregate([

    // Rename the fields and process the result field
    { $project : {
          tag : 1,
          case : "$case_id",
          date : "$uploaded_at",
          result : {
              passing : { $cond : [ { $eq : ["$result","passing"] }, 1, 0 ] },
              failing : { $cond : [ { $eq : ["$result","failing"] }, 1, 0 ] }}
    }},

    // Create a stream of documents from the tag array 
    { $unwind : "$tag" },

    // Sort by uploaded date descending
    { $sort : { date : -1 }},

    // Group the documents by tag and case_id, and use $first operation to get the latest log for each group
    { $group : {
          _id : { tag : "$tag", case : "$case" },
          latest : { $first : "$result" },
    }},

    // Group the document by tag, and caculate the total/pass/fail results
    { $group : {
          _id : "$_id.tag",
          total : { $sum : 1 },
          passing : { $sum : "$latest.passing" },
          failing : { $sum : "$latest.failing" }
    }}
])