akka-persistence

8熱

1答えて

akka-persistanceを使用したイベント調達：状態をリストとして増やすか？

私はAkka + Scalaを使用して、CQRS +イベントソーシングを使用してバックエンドを設計しています。私は成長している状態に対処する方法についてはわかりません。たとえば、ユーザーのリストが増えます。私の理解では、各ユーザーはUserCreatedイベントの後に作成され、そのようなイベントはPersistentActorによって再生され、ユーザーはコレクションに格納されます。以下のような何か

7熱

2答えて

Akka Persistence QueryイベントストリームとCQRS

私はES-CQRSアーキテクチャで読み取り側を実装しようとしています。私の知る限り理解し object UserWrite { sealed trait UserEvent sealed trait State case object Uninitialized extends State case class User(username: String,

3熱

1答えて

AKKAパーシステンスとESとCQRSの原則を理解する

私は最近、ESとCQRSモデルについていくつかのビデオを見てきましたが、AKKAパーシステンスについてはほとんど話をしていませんでした。私は彼らが何をしているのか知っていますが、実行する実際のコードを書くのに問題があります。私は少し質問があります。ビューとイベントスタックをどのように通信させるべきですか？同じ永続性IDのビューと永続アクタの間でイベントが渡されますか？モデルに応じた永続アク

1熱

1答えて

アッカは、一例として、 `PersistentActor`

case class State(id: Long, remain: Int) { def take(t: Take) = copy(remain = remain - t.amount) } object StateService { def getInitState(id: Long): Future[State] } sealed trait Evt cas

1熱

1答えて

一度だけジャーナルを読む

私はakka-persistenceのPersistenceQueryを使って、物を管理するアクタに初期状態を読み込みます。私は起動時に1回だけ再生することを望みますが、ログを送信し続けます。 14:11:28.405 [rooms-akka.actor.default-dispatcher-4] DEBUG a.p.q.j.l.LiveEventsByPersistenceIdPublisher

2熱

1答えて

Akkaは最初のメッセージの後に回復完了の更新状態を維持します

私は永続的な俳優を持っています。最初（データベースが空である）に開始するとき、私はいくつかの初期データを保持します。しかし、状態は私が期待するように更新されません。最初のメッセージが処理された後で更新されます。状態の更新後に俳優にメッセージの処理を開始させる方法を教えてください。あなたは再考したい俳優コード class TestActor extends PersistentActor {

0熱

1答えて

Akka Persistence Journalをすべての俳優に再生することは可能ですか？

私は、Akka Persistence Journalといくつかのデータベースで、ジャーナルに保存されているデータのビューを提供しています。ほとんどのビューには、複数のエンティティ（ - >複数の永続アクタ）が含まれています。 1つのアクタのリカバリをトリガすることができますが、そのエンティティのみで構成されるビューを再構築することができますが、すべてのビューを再構築する場合はどうすればよいですか

1熱

1答えて

Akka Persistence Cassandra：タイムスタンプ！=オフセット。またはイベントを一度だけ処理する方法は？

私は現在、Akka PersistenceとCassandra Journal Pluginでイベントソースアプリケーションを構築しています。私はいくつかのビューを持っているので、複数の永続性IDのイベントを取得する必要があります。したがって、eventsByTagクエリを使用してmongodbビューを更新しています。アプリケーションを再起動すると、クエリが再生されるため、何らかの形でビューの

5熱

1答えて

永続アクターをAkka永続性でどのように構成する必要がありますか？

Akkaの永続的な（Eventsourcing/CQRS）で私のアクターをどのように構造化すればよいですか？階層パラレル私は私のeコマースアプリケーションユーザーにこれらのドメインオブジェクトを持っている - ユーザーアカウントストアを作成することができます - ユーザーが店舗を作成することができます製品 - ユーザーは店舗に製品を追加できますカート - ユーザーは、他のユーザーの店

1熱

1答えて

Akkaは永続的なメッセージを削除します

私は機器で発生したイベントを処理するアプリケーションを作成しています（毎時100万）。いくつかのイベントは、開始イベント、ステータス（x-times） - イベントおよび終了イベントを含む集約されます（長時間（たとえば48時間））。他はすぐに処理できる単一のイベントです。イベントが処理されることを少なくとも1回保証するために、私はakka-persistenceを見ています。アプリケーションの他の