事件源是一种设计模式,它将应用程序状态的所有更改捕获为一系列事件。
我们目前正在研究如何将 Marten 实现为我们的整体应用程序的事件存储。为简单起见,场景范围如下: 一款整体式应用程序: 存储事件我...
EventFlow NETCore 8 - ReadModelByIdQuery 从数据库解析数据无效
我有一个带有 EventFlow 的 WebApi。它在 .NET Core 2.1 上运行良好,但我将其升级到 .NET 8。并且出现了问题。当我尝试使用 ReadModelByIdQuery 应用程序抛出 InvalidOperationException 时。它瞧...
最近迁移到最新版本的 MartenDB 6.4.0,并在尝试查询 postgres 数据库中的流事件列表时开始看到以下错误 代码 等待_querySession.Events。
我正在使用 Kafka 进行事件溯源,并且我对使用 Kafka 实现 sagas 感兴趣。 有关如何做到这一点的最佳实践?这里提到的Commander模式看起来和架构很接近……
Akka:currentEventsByPersistenceId 始终为“eventEnvelope.timestamp”返回零
我正在尝试使用 akka-persistence-query 中的 currentEventsByPersistenceId 查询来检索和处理消息表中存储的事件。但是,我遇到了一个问题,
在 Akka 类型化事件溯源中,对多个类型化持久实体使用单个数据库(相同的事件日志)是否很常见?
假设在应用程序办公室中有两个EventSourcedBehavior actor 特质 OfficeFridgeCommand 案例对象 OpenFridge 扩展 OfficeFridgeCommand 案例对象 CloseFridge 扩展了 OfficeFridgeComm...
DDD+CQRS+EventSourcing 如何确保预测是最新的?
我们开发使用DDD、CQRS+Eventsource的应用程序。 我们有一个 UserAggregate。此聚合使用 UserMailIndex。 UserMailIndex - 是一个投影,它只是唯一电子邮件的列表。每次...
.net 编写的应用程序尝试使用 EventStore.Client.Grpc.Streams 23.1.0 读取事件流。逻辑如下: 尝试读取流 如果没有流(或流版本为0)我们...
我正在 ES 和 CQRS 的世界中冒险,我已经阅读了很多相关内容。不幸的是,大多数材料并没有超出基础知识,当您开始尝试将其应用到现实世界时
我正在尝试对消耗来自 Disruptor 环形缓冲区的消息的应用程序进行单元测试。在测试中我想 配置扰乱器及其事件处理程序 将消息发布到环上
使用 CQRS 时,我们使用两个独立的存储进行操作。在这种情况下同步操作到底是如何执行的? 假设我使用事件存储数据库进行写入存储和 Elasticsearch...
假设我正在实现一个使用事件源管理股票和投资组合的应用程序。我有以下命令: 创建投资组合 买入股票 卖出股票 关闭投资组合 处理...
事件溯源通常意味着每个聚合 id 有一行: 事件ID 事件类型 实体类型 实体ID 事件数据 102 订单已创建 命令 101 {...} 103 订单已更新 命令 101 {...} 但我...
我有一个使用 Akka 和 Cassandra 进行事件溯源的应用程序。作为 API 响应的一部分,我需要显示发生的特定类型/标签(例如 UpdateEvent)的事件数量...
在 DDD 中是否建议将事件存储和事件总线与事件溯源相结合?
我目前正在探索领域驱动设计 (DDD)、事件溯源和 CQRS。我正在寻求澄清是否建议对事件存储和事件总线使用单个组件。该...
我正在构建一个遵循干净架构方法的应用程序。它试图确保领域层独立于任何基础设施层。但我看了很多例子
考虑以下场景: 事件源聚合管理包的传输 它可以接收诸如“包裹在早上 5 点加载”、“包裹在早上 7 点停止在这里......”之类的命令。
我正在努力解决事件溯源中的一个场景。 我有订单拣选系统,可以准备订单。 我注册了订单准备事件,pickedQuantity>requestedQuantity 我是
我正在使用 Java 和 Cassandra 的事件溯源从头开始构建一个项目。 我的应用程序基于微服务,在某些用例中信息将被异步处理。我赢了...