事件来源和CQRS，我错过了什么？

Question

我开始阅读与CQRS相结合的事件源模式。据我所知，CQRS模式是一种将写操作和读操作分开的模式。事件源是一种模式，系统中的一切都由触发事件的命令启动。事件源模式需要一个事件总线。有几件事我没弄明白。

事件存储区包含发生在某个实体上的所有事件。如果我想查询这个实体的当前状态，我需要查询发生在这个实体上的所有事件，并重新创建它的当前状态。
所有事件历史记录都在事件存储区中。
为什么我不能有一个负责将每个事件保存到事件数据库中的微服务（如果我想记录这些事件以进行进一步操作。类似于Kafka）和一个单独的微服务来更新常规数据库中实体的更改（例如，在MongoDB中对实体文档的简单更新）。当这些微服务完成它们的工作时，这个事件将从事件存储区中移除（假设我使用队列实现了这个事件存储区）。这样，每当我需要查询实体的当前状态时，我只需查询一个数据库，而不是查询事件存储并重新构建当前状态（或者根据事件存储重新计算状态并定期缓存结果）。我不明白为什么强制永远存储所有事件，为什么不是可选的？

例如，接收事件的Lambda函数生成事件，并将它们存储在每个事件类型的单独SQS中。每个SQS都有自己的负责处理相应事件类型的lambda函数。事件一旦处理完毕就会移除。

Answer 1

事件源模式需要一个事件总线。

事件源不需要总线，除非您需要将更改（事件）通知其他系统/域。

如果我想查询这个实体的当前状态，我需要查询这个实体发生的所有事件，并重新创建它的当前状态。

你可以的！

当这些微服务完成它们的工作时，这个事件将从事件存储区中移除（假设我使用队列实现了这个事件存储区）。

你也可以这样做，但你不做事件来源。这更像是“事件驱动的体系结构”，它不使用事件源是可能的，也是完全有效的，但并没有提供所有相同的好处。在事件源系统中，事件存储是数据真实值的来源，队列不是存储真实值的有效位置，因为它实际上并不是要长期存储数据。