Постоянные реляционные проекции в RailsEventStore

Question

Я пытаюсь создать приложение Rails 5.2.x на основе CQRS и источников, используя RailsEventStore.

Теперь я хотел бы спроецировать свой поток событий в реляционную модель, в идеале просто используя ActiveRecord и базу данных PostgreSQL.также используется для моего хранилища событий.

В документации RailsEventStore я обнаружил только непостоянные проекции на лету.

Существует ли какая-либо инфраструктура для непрерывного построения и обновления реляционныхпредставление потока событий?Необходимо запомнить, какие события уже были применены к реляционной модели при перезапуске приложения.

Если вы знаете, как это сделать, пожалуйста, дайте мне знать.

Answer 1

В RailsEventStore не существует готового фонового процесса для поддержки постоянных проекций так же, как это делает база данных EventStore.

Однако есть фрагменты, которые можно объединить вместедобиться чего-то похожего - обработчики событий и связывание .

Мой коллега Рафал собрал несколько постов, документирующих этот подход:

• https://blog.arkency.com/using-streams-to-build-read-models/
• https://blog.arkency.com/read-model-patterns-in-case-of-lack-of-order-guarantee/

Если выЯ хотел бы реализовать такую ​​проекцию как отдельный фоновый процесс, а не полагаться на обработчики событий (синхронные или нет), тогда Distributed RailsEventStore с PgLinearizedRepository может быть хорошей отправной точкой.