イベントソーシングとは何ですか？どのように動作しますか？

Question

IT Interview Practice · Accepted Answer

## イベントソーシングとは？

**イベントソーシングは、発生したイベントを正本となるデータとして保存し、その履歴から現在の状態を導き出す方式です。** 各イベントには、「カートに商品を追加した」「注文をキャンセルした」といった業務上の変更を記録します。

カートに本が一冊入っているという事実だけでなく、顧客が二冊追加し、その後一冊を取り除いたことまで把握できます。この履歴は単に参照用として残すのではなく、カートの状態を再構築するために使います。

## 主な構成要素

- **リクエストハンドラー：** ユーザーが実行したい操作を確認します。無効なリクエストは拒否され、発生した事実を記録するイベントにはなりません。
- **イベントストア：** 個々のカートなど、エンティティごとに順序付きのイベント列を保持します。この列をイベントストリームと呼びます。
- **状態の再構築ロジック：** イベントを順に読み取って適用し、現在のデータを計算します。クエリを高速化するために、アプリケーションが読み取り用のビューをあらかじめ維持することもできます。

## 例：カートを再構築する

カートに次の履歴があるとします。

1. カートを作成：カートは空です。
2. 本Aを二冊追加：カートには二冊入っています。
3. 本Aを一冊削除：一冊が残ります。

この三つのイベントを順に読み取って適用すると、本Aが一冊という同じ結果になります。このように記録済みの履歴を適用して状態を計算することを、**リプレイ**と呼びます。

顧客がさらに商品を追加すると、システムはリクエストを確認して新しいイベントを追記します。二つのリクエストが同時にカートを変更する場合、追記時に読み取り済みのストリームのバージョンを確認し、変更の競合を検出する必要があります。

リプレイはデータを再構築する処理です。確認メールを再送したり、決済を再実行したりしてはいけません。

## 利点

- **変更の理由を説明できる：** どの操作が現在の状態につながったのかを履歴から確認できます。
- **クエリ用データを再生成できる：** 完全なイベント履歴が保持されていれば、表示用のテーブルやレポートを再計算できます。
- **過去の状態を確認できる：** ある時点までのイベントを適用すれば、その時点のエンティティの状態が分かります。

## 考慮すべきコスト

- **増え続ける履歴：** スナップショットには、ストリームのある位置で計算した状態を保存します。これにより、再構築にはその後のイベントだけが必要になります。
- **古いイベントとの互換性：** データ構造が変わっても、新しいコードは記録済みの履歴を引き続き解釈できなければなりません。
- **明示的な訂正：** 通常は古いデータをひそかに上書きせず、履歴を保つために訂正イベントを追加します。

## どのような場合に使いますか？

イベントソーシングは、契約のライフサイクルや繰り返される注文の調整など、変更履歴が業務の重要な一部となる領域に適しています。履歴を保持し、処理する作業に見合う利点が必要です。

アプリケーションに最新の状態と確認用の記録だけが必要なら、通常の保存方式に監査ログを組み合わせる方が単純な場合があります。

イベントソーシングとは？

主な構成要素

例：カートを再構築する

利点

考慮すべきコスト

どのような場合に使いますか？

関連する質問