AWS Lambda로 서버리스 CQRS + EventSourcing ReadModel 업데이트

Question

AWS 서버리스 아키텍처를 기반으로하는 CQRS + Event Sourcing 백엔드를 구현하려고합니다. 문제는 readmodel 업데이트 문제입니다.

이벤트가 이벤트 저장소에 저장되면 SNS에 게시됩니다. 그런 다음 SNS가 UpdateReadModel 람다를 호출합니다. 여러 개의 순차적 이벤트가 SNS에 게시되면 여러 개의 람다가 호출됩니다.

첫 번째 문제는 모두 동일한 ReadModel 업데이트를 수행하고 실제로 모든 이벤트에 대해 하나의 람다 만 호출해야한다는 것입니다.

두 번째 문제는 몇 번의 람다 실행 후 최종 ReadModel 상태가 손상 될 수 있다는 점입니다.

ReadModel 당 정확히 하나의 람다가 호출되어야합니다.

가능한 솔루션 :

1. 사용 MessageBroker에 (RabbitMQ 또는 카프카) + EC2 인스턴스는 UpdateReadModelLambda를 호출합니다.

2. SNS + EC2 인스턴스 다음에 SQS를 추가하고 Samba에서 lambdas 및 get 이벤트를 호출하는 코드를 작성하십시오.

하지만 인스턴스를 사용하지 않는 이유는 서버리스 방식에 적합하지 않기 때문에 개발자가 직접 컨테이너 나 MessageBus를 관리하고 크기를 조정해야하기 때문입니다.

어쩌면 누구나 이미 클라우드 서비스 + CQRS + EventSourcing에 대해이 문제를 해결했거나 다른 솔루션을 가지고있을 것입니까?

Answer 1

예상 메시지 브로커를 사용하는 것은 좋지 않습니다. 주문을 보장 할 수는 없으며 한 번의 배송 만 보장 할 수는 없으며 다른 읽기 모델이 동일한 이벤트를 다시 가져올 수 있기 때문에 하나의 읽기 모델 만 이벤트를 재생할 수 없습니다. 재생할 때 통합 이벤트도 발생하므로 이벤트 기반 시스템을 사용할 수 없습니다. 나는 그렇게하지 않을 것이다.

이벤트 저장 작업 (예 : Dynamo 삽입)에 의해 트리거 된 람다 함수를 사용할 수 있습니다. 각 람다는 하나의 집계 유형에 대한 투영 모음이거나 하나의 단일 투영 일 수 있습니다. 그래도 재시도가 발생하면 이벤트가 발생할 가능성이 있으며 그곳에서 병렬 처리를 비활성화 할 수 있는지 잘 모르겠습니다.