복합 키 최대 평가 $

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을 두 번 그룹화 한 후 결과가 최신 로그 만 필요합니다. 각 tag에 대해 upload_date 각 계수는 주어진 케이스의 최신 로그에 해당

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

:

편집

내 예상 결과는 무엇인가 같다. $max documentation 당

Answer 1

이 오퍼레이터

이 그룹에 의해 선택된 모든 문서에서 필드의 모든 값 중에서 가장 큰 값을 반환.

집계 작업은 다음과 같이이다 :

당신은 { "$의 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 필드로 모든 로그를 정렬하고 정렬 된 결과를 tag 및 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" } 
    }} 
])