[mongoDB]Mapreduce 몽고디비 맵리듀스

[mongoDB]Mapreduce 몽고디비 맵리듀스

대용량 데이터처리 하면 많이 나오는 단어가 mapreduce인데요

mapreduce는 map이라는 과정과 reduce라는 과정을 거쳐 관련있는 데이터끼리

모아 빠르게 처리하는 기술을 말합니다.

몽고디비에서도 mapreduce기능이 있는데요

먼저 샘플데이터를 넣어보겠습니다.

map_function이라는 이름으로 map과정을 만들어 보겠습니다.

cust_id와 price를 뽑아오는 함수를 만들었죠.

reduce_function에서는 고객 키에 대한 price의 합계를 구하고있는걸 볼 수 있습니다.

위에서 만든 함수를 이용해 mapreduce를 실행시키면

map과 reduece함수를 통해 원하는 결과가 만들어지는것을 볼 수 있습니다.