DDD \ CQRS \ Event Sourcing и запросить исторические данные

Question

Я прочитал книгу Patterns, Principles, and Practices of Domain-Driven Design Мне очень понравился подход к использованию DDD вместе с CQRS и Event Sourcing. Но у меня есть один вопрос. Как использовать DDD \ CQRS \ Event Sourcing можно получить исторические данные? Например. Я хотел бы написать службу, которая предоставляет информацию о погоде. Клиент может запрашивать данные службы. Например, Снимок погоды в Лондоне в прошлом году, шаг за шагом для рисования графики и клиента может подписаться на данные в реальном времени для обновления уже построенной графики. Вопрос. Как использовать DDD \ CQRS \ ES подход для отправки исторических данных клиенту, который запросил их. Я не могу отправить событие непосредственно на шину сообщений, потому что у службы может быть несколько клиентов, и не все клиенты нуждаются в этих данных.

Обновление.

Я хотел бы показать в клиенте что-то вроде этого.

Answer 1

Обычно, чтобы получить исторический вид, вы загрузите агрегат только с событиями до интересующего вас периода времени. Это даст вам представление моментального снимка в то время.

Как вы получаете текущий вид погоды? Загрузка всех погодных событий за все время для запрашиваемого местоположения?

Если весь графический чертеж и т. Д. Выполняется клиентами, и вы просто доставляете события, то вы можете просто разрешить клиентам запрашивать часть потока событий через ваш api. Вы не стали бы «публиковать» эти события снова для всех клиентов, поскольку это уже произошло. Клиенты будут либо называть ваш api, чтобы получать уведомления о «новых» событиях, либо получать «исторические» события, или получать события с момента, следующего за новыми событиями.

По крайней мере, это мое понимание того, как это будет работать.

Answer 2

Если я правильно понял ваш вопрос, вы хотите запросить данные. Внутри CQRS существует разделение между получением данных (через запросы) и записью/настройкой данных (через команды). Каждый раз, когда вы хотите изменить данные (через команду), вы запускаете событие и сохраняете его в EventStore. Вы можете использовать Projection для создания презентации, которую хотите использовать для данных, вы даже можете сохранить ее в другой базе данных.

Постараюсь eleborate на вашем примере:

• каждый час событие обжигают в EventStore с текущими погодными условиями и DateTime измерения (это может быть решением для импорта старых данных)
• eventstore, запускает проекцию (с вашей собственной желаемой презентацией), которая сохраняется в другой базе данных (которую вы можете легко запросить)
• это база данных доступна по запросам.

Можно было бы оставить другую базу данных, но это может быть решение представить запросы быстрее, потому что эта база данных (с его репликами) несет ответственность только для чтения в вашем приложении, в то время как ваш eventstore делает все тяжелый подъем (пишет).