DB 변동사항 실시간 통보해주기(change stream)

데이터가 변동이 되어도 서버에서는 감지할 수가 없다. 따라서 이번에는 DB 데이터의 실시간 변화를 감지해서 DB가 서버에 알려주는 기능을 해보자.

 

 

 

const pipeLine = [
    { $match: { } }
]; // 찾을 문서

//예시
//const pipeLine = [
//    { $match: { 'fullDocument.parent': request.user._id } } //fullDocument는 필수로 붙여야함.
//];
  
const changeStream = db.collection('message').watch(찾을문서); //어느 콜렉션에서 찾을 문서가 있는지 감시할지

changeStream.on('change', (result) => { //변동 사항이 생길 경우 작동
    console.log(result.fullDocument);
});