이 포스팅은 nact.io 공식 홈페이지를 번역한 글입니다.
[NEW] 이제 공식 사이트에서도 한글 문서가 제공됩니다. https://nact.io/ko_kr

퍼시스턴트 쿼리

저장된 이벤트가 많을 때 스냅샷 기능을 이용하면 액터의 상태를 복원할 때 성능상 이득을 볼 수 있다는 것을 알았습니다. 그런데 어떤 때는 이벤트 목록 자체가 필요할 수 있습니다.

예를 들면, 어떤 도메인 엔티티에 변화를 일으키는 트랜잭션 목록을 보고 싶은 때가 있을 수 있습니다. 항상 필요하지는 않지만 그래도 언젠가는 필요할 때가 있습니다. 그런데 만약 이것 때문에 이벤트 목록 자체를 상태로 저장해버린다면, 이벤트 목록까지 포함된 스냅샷이 점점 커져서 비효율적이게 됩니다.(상상해보십시오) 이 문제는 CQRS 패턴으로 해결할 수 있습니다.

Nact는 CQRS의 경량화된(그러나 강력한) 형태로서 퍼시스턴트 쿼리 기능을 제공합니다. 퍼시스턴트 쿼리에는 퍼시스턴트 키를 입력받아 저장된 이벤트를 메시지 핸들러에 재생하는 함수를 리턴합니다. 이 함수는 Promise에 담긴 결과를 반환합니다. 퍼시스턴트 쿼리는 지연 평가되어(lazy evaluation) 사용할 때 비로소 실행됩니다.¹ 참조될 때마다 반복적으로 실행되고, 혹시 새 이벤트가 있으면 역시 반영됩니다. 퍼시스턴트 쿼리의 결과와 시퀀스 번호(이벤트가 저장될 때 순서대로 부여되는 번호)는 별도로 설정된 타임아웃 값에 따라서 캐시되고, 또 일정 메시지마다 스냅샷을 저장하도록 할 수 있습니다.

아래에서 퍼시스턴트 쿼리를 유용하게 사용하는 실용적인 예를 볼 수 있습니다. 이 예제는 지갑을 간단히 모델링한 것입니다. 액터의 상태에는 현재 잔액, 아이디, 금전 출납 기록에 대한 퍼시스턴트 쿼리 등이 있습니다. 이 예제에서 주목해야 할 것은 encoder와 decoder를 사용한 부분입니다. 이는 액터의 상태가 단지 정적인 데이터가 아니라 퍼시스턴트 쿼리와 같은 동적 데이터를 포함하고 있을 때 필요합니다.

const transactionsQuery = (parent, id) =>
  persistentQuery(    
    parent,
    (state = [], msg) => {
      if (msg.type === 'transaction') {
        return [msg, ...state]
      } else {
        return state
      }          
    },
    `wallet${id}`,
  )

let snapshotDecoder = (parent) => (json) => ({
    id: json.id,
    balance: json.balance
    transactions: transactionsQuery(parent, json.id),
})

const initialState = (id, parent) => ({  
  balance: 0,
  id:walletId,
  transactions: transactionsQuery(parent, id),    
})

let spawnWallet = (walletId, parent) =>
  spawnPersistent(
    parent,        
    async (state = initialState(walletId, parent), msg, {recovering, persist}) => {
      switch (msg.type) {
        case 'transaction':          
          if (!recovering) {
            await persist(msg)
          }
          return { ...state, balance: state.balance + msg.amount }
        case 'get_transactions':                    
          dispatch(msg.requestee, await state.transactions())
          return state
        default: 
          return state
      }
    },
    `wallet${walletId}`,
    walletId,
    {
      snapshotDecoder: snapshotDecoder(parent),        
      snapshotEvery: 5 * messages,
    }    
  )

퍼시스턴트 액터와 퍼시스턴트 쿼리의 같은 점과 다른 점

퍼시스턴트 쿼리는 액터와 같은 라이프사이클이 없습니다. 그래서 shutdownAfter 같은 함수도 없습니다. 그러나 퍼시스턴트 쿼리의 결과는 메모리에 캐시될 수 있습니다. 캐시는 cacheDuration 옵션을 사용해서 유효 기간을 제한하지 않으면 지속됩니다.

퍼시스턴트 쿼리는 encoder와 decoder를 사용할 수 있습니다. 이 때 퍼시스턴트 액터와 마찬가지로 각각의 결과는 스냅샷으로 저장할 수 있습니다. 다른 점으로, snapshotEvery 속성 외에 snapshotKey도 지정해야 합니다.

References

• nact.io 공식 홈페이지
• [nact.io] 3.4 Persistent Queries