事件溯源需要多少个数据库或表?

如何解决事件溯源需要多少个数据库或表?

我正在尝试使用事件源、ddd 和 cqrs。 我无法理解我必须创建两个数据库(或表)(1-json 2-normalize 数据库)或一个数据库(只是 json) 而且,如果我创建了两个数据库(或表),我是否必须在一个事务中将数据库(json 和 normalize)中的数据保存为原子? 最好的问候

解决方法

我不明白我必须创建两个数据库(或表)(1-json 2-normalize 数据库)或一个数据库(只是 json)

只需要一个活动商店就可以了,别无其他。

然而,“过得去”并不一定令人愉快。通常,事件存储非常擅长“追加新信息”,但不是特别擅长“查询”。因此,通常的答案是部署流程,将信息从您的事件存储复制到具有更好查询支持的内容。

我是否必须将数据库中的数据(json 和规范化)保存为一个事务中的原子数据?

仅更新事件存储,然后调用流程将信息从事件存储复制到您的查询支持是一种常见模式。当然,这也意味着您的查询最终可能会显示过时/过时的信息(这是截至五分钟前您的问题的答案)。

如果您将查询友好数据模型与事件存储(例如,同一关系数据库中的表)一起存储,那么您可以安排至少一些对查询友好模型的更新与事件同步。

换句话说,您需要权衡取舍,而不是到处使用的单一模式。

,

DDD

我们在此假设您完全了解使用 DDD 及其含义。具体与事件溯源相关,它是定义聚合边界和成为其状态的事件的问题。

CQRS

我们再次假设您完全理解其中的含义。 CQRS 仅允许您在垂直切片(即从 UI 到数据库)中编写代码,以便将“命令”与处理“查询”的代码分开。就这样。虽然您确实可以更进一步,但通过将数据存储在“读取模型”中,该模型甚至可能位于不同的数据库中,更不用说表了,但这不是实现 CQRS 的要求。

由于 CQRS 与事件溯源相关 - 它非常适合,因为您在事件溯源中最终使用的数据模型不利于复杂查询。它通常仅限于“通过 ID 获取聚合”。因此,使用“投影”以其他更适合查询和加载到 UI 的方式存储数据是典型的方法。

事件溯源

如果您以这样一种方式实现领域模型,即聚合处理的每个命令(即用户执行的每个用例/任务)都会生成一个或多个事件,那么事件溯源就是您存储这些事件的原则针对聚合的 ID 以仅附加样式的事件列表,而不是在成功处理命令后存储聚合的快照。

要从事件存储加载聚合,您需要加载它之前的所有事件,并在内存中的 Aggregate 对象上重放它们,而不是将单个行/文档作为快照/备忘录加载。

因此,文档数据库是事件存储的绝佳选择,因为单个文档表示给定聚合的事件流。但是,如果您想将事件流存储在 SQL 中,那很好,但您可以将其存储在两个表中:

create table Aggregate (Id int not null...);
create table AggregateEvent(AggregateId int not null FK...,Version int not null,eventBody nvarchar(max));

实际的事件主体通常是事件本身,序列化为 JSON 等文本格式。

投影和读取存储

如果您获取通过聚合处理命令生成的事件,并通过写入单独的数据存储(SQL、预先计算的 ViewModel 等)来编写使用它们的代码,那么您可以将其称为“投影” .它将处于一种形状的数据“投影”为适合不同目的的另一种形状。结果是“读取存储”,然后您可以根据需要进行查询。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


使用本地python环境可以成功执行 import pandas as pd import matplotlib.pyplot as plt # 设置字体 plt.rcParams['font.sans-serif'] = ['SimHei'] # 能正确显示负号 p
错误1:Request method ‘DELETE‘ not supported 错误还原:controller层有一个接口,访问该接口时报错:Request method ‘DELETE‘ not supported 错误原因:没有接收到前端传入的参数,修改为如下 参考 错误2:cannot r
错误1:启动docker镜像时报错:Error response from daemon: driver failed programming external connectivity on endpoint quirky_allen 解决方法:重启docker -> systemctl r
错误1:private field ‘xxx‘ is never assigned 按Altʾnter快捷键,选择第2项 参考:https://blog.csdn.net/shi_hong_fei_hei/article/details/88814070 错误2:启动时报错,不能找到主启动类 #
报错如下,通过源不能下载,最后警告pip需升级版本 Requirement already satisfied: pip in c:\users\ychen\appdata\local\programs\python\python310\lib\site-packages (22.0.4) Coll
错误1:maven打包报错 错误还原:使用maven打包项目时报错如下 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-resources-plugin:3.2.0:resources (default-resources)
错误1:服务调用时报错 服务消费者模块assess通过openFeign调用服务提供者模块hires 如下为服务提供者模块hires的控制层接口 @RestController @RequestMapping("/hires") public class FeignControl
错误1:运行项目后报如下错误 解决方案 报错2:Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile (default-compile) on project sb 解决方案:在pom.
参考 错误原因 过滤器或拦截器在生效时,redisTemplate还没有注入 解决方案:在注入容器时就生效 @Component //项目运行时就注入Spring容器 public class RedisBean { @Resource private RedisTemplate<String
使用vite构建项目报错 C:\Users\ychen\work>npm init @vitejs/app @vitejs/create-app is deprecated, use npm init vite instead C:\Users\ychen\AppData\Local\npm-
参考1 参考2 解决方案 # 点击安装源 协议选择 http:// 路径填写 mirrors.aliyun.com/centos/8.3.2011/BaseOS/x86_64/os URL类型 软件库URL 其他路径 # 版本 7 mirrors.aliyun.com/centos/7/os/x86
报错1 [root@slave1 data_mocker]# kafka-console-consumer.sh --bootstrap-server slave1:9092 --topic topic_db [2023-12-19 18:31:12,770] WARN [Consumer clie
错误1 # 重写数据 hive (edu)> insert overwrite table dwd_trade_cart_add_inc > select data.id, > data.user_id, > data.course_id, > date_format(
错误1 hive (edu)> insert into huanhuan values(1,'haoge'); Query ID = root_20240110071417_fe1517ad-3607-41f4-bdcf-d00b98ac443e Total jobs = 1
报错1:执行到如下就不执行了,没有显示Successfully registered new MBean. [root@slave1 bin]# /usr/local/software/flume-1.9.0/bin/flume-ng agent -n a1 -c /usr/local/softwa
虚拟及没有启动任何服务器查看jps会显示jps,如果没有显示任何东西 [root@slave2 ~]# jps 9647 Jps 解决方案 # 进入/tmp查看 [root@slave1 dfs]# cd /tmp [root@slave1 tmp]# ll 总用量 48 drwxr-xr-x. 2
报错1 hive> show databases; OK Failed with exception java.io.IOException:java.lang.RuntimeException: Error in configuring object Time taken: 0.474 se
报错1 [root@localhost ~]# vim -bash: vim: 未找到命令 安装vim yum -y install vim* # 查看是否安装成功 [root@hadoop01 hadoop]# rpm -qa |grep vim vim-X11-7.4.629-8.el7_9.x
修改hadoop配置 vi /usr/local/software/hadoop-2.9.2/etc/hadoop/yarn-site.xml # 添加如下 <configuration> <property> <name>yarn.nodemanager.res