MongoDB에서 공유 mapreduce 결과 모음

Question

mapwduce를 실행중인 Mongoid 모델이 여러 개 있습니다. 통합 결과를 단일 daily_stats 모음에 저장하고 싶습니다. 내지도 &이 기능은 모든 3 개 모델에 잘 작동 감소하지만, collection.mapreduce(map, reduce, {:out => "daily_stats", :raw => true})를 통해 출력 할 경우에도, 다음지도의 결과는 작업이 이전 결과를 덮어 감소 심지어 그들이 중복 키가 없습니다 : photos에 대한

{'_id': "2012-06-01", 'values': {photos: 10}} 
{'_id': "2012-06-02", 'values': {photos: 10}} 

값

{'_id': "2012-06-01", 'values': {comments: 1}} 
{'_id': "2012-06-02", 'values': {comments: 6}} 

내가 collection.mapreduce(map, reduce, {:out => {:merge => "daily_stats"}, :raw => true})과도 병합했지만, 그 중 하나가 작동하지 않는 것 : 후속 패스가 반환 할 때 밖으로 던져.

아이디어가 있으십니까?

UPDATE

&이 기능 감소지도는 각 모델이 같다 :

가

지도 :

function() { 
    day = Date.UTC(this.created_at.getFullYear(), this.created_at.getMonth(), this.created_at.getDate()); 
    emit(day, {users: 1}); 
    }; 

가 감소 : 기능 (키, 값) { var에 users_added_count = 0;

{ "_id" : 1337040000000, 
"value" : { 
    "apartments" : 280, 
    "price" : 1003653, 
    "photos" : 83, 
    "comments" : 0 } 
} 

Answer 1

당신이 감소 맵의 MongoDB를 문서 (보면 http://www.mongodb.org/display/DOCS/MapReduce# :

values.forEach(function(v) { 
     users_added_count += parseInt(v['users']) || 0; 
    }); 

    return {users: users_added_count}; 
    } 

다음 결과 스키마에 대한 몇 가지 추가 정보입니다 MapReduce-Outputoptions)을 사용하면 기본적으로 MR 출력 콜렉션이 동일한 이름을 가진 기존 콜렉션을 대체한다는 것을 알 수 있습니다. "병합"은 새 데이터를 이전 출력 컬렉션에 추가하지만 동일한 키가있는 문서를 덮어 씁니다.

열쇠가 날짜 인 것 같습니다.

{'_id': "2012-06-01", 'values': {photos: 10}} 

및

{'_id': "2012-06-01", 'values': {comments: 1}} 

동일한 키가있는 경우는 MR을 실행할 때, 두 번째 문서는 첫째 대체합니다. 보다 고유 한 키를 지정하거나 여러 개의 출력 콜렉션을 가져야합니다 (사진 및 주석 중 하나 일 수 있습니다). 당신은 해시 키를 방출 할 수

Answer 2

는

emit({day: day, type: '<model class name>'}, 1);