在 CQRS 模式 + 事件源中读取 "latest data" 的使用模式
Usage pattern to read the "latest data" in a CQRS pattern + Event Sourcing
我正在使用 CQRS（命令查询责任分离）模式实施一个测试项目。
我有几个问题。
我想在购买前检查用户购物车中某件商品在数据存储中的最新价格。因此，real_model（通过物化视图）价格将根据数据存储（产品 table）上的最新价格进行检查。如果价格之间存在差异，我想向用户显示警报。实现此目标的最佳方法是什么？
当用户更新他们的Email和Password时，是否仍然依赖于创建事件来更新DataStore（Event->EventStore->Service Bus->DataStore）还是直接更新Data Store？我不希望延迟触发 read_model_update 的事件，因为用户必须立即重新登录。
I want to check the latest price on the data store for an item on a users shopping cart just prior to purchasing... What is the best way to achieve this?
我怀疑 "best way to achieve this" 将在很大程度上取决于您的利益相关者希望提供给客户的购物体验。 IE - 什么时候应该锁定价格？例如，购物车中显示的价格可能是有时间限制的实盘。
但是请原谅那些细节...
一种方法是 运行 在发送命令之前对读取模型进行健全性检查。有一种常见模式（有效地）检查命令在给定读取模型的状态下是否有效，然后调度临时验证的命令以更新记录簿。您可以用一些延迟换取更低的故障率。
另一种可能是使用进程管理器；这个想法是 "placeOrder" 不是对模型的简单写入，而是生命周期的开始。因此，假设报价是您模型中的一个东西——当将商品放入购物车时，将生成报价（可能具有一些过期值）。当价格发生变化时，所有不同的报价都会更新。下订单时，处理程序会看到 placedOrder 事件，并尝试对报价调用 acceptQuote 方法；如果报价仍然有效，则生成的事件会将订单流程推进到下一个状态。如果引用不再有效，则生成不同的事件，或者命令被拒绝，最终超时表明可能存在问题....
（您可以尝试对产品本身做一些类似的事情，但由于争用问题，效果不佳；唯一知道您正在使用 the 的方法对象的最新状态是记录簿接受对其的写入。）
Udi Dahan 的 Race Conditions Don't Exist 评论可能会有用。
When the User updates their Email and Password should it still rely on creating events to update the DataStore (Event->EventStore->Service Bus->DataStore) or directly update the Data Store?
没有直接更新 -- 所有对读取模型的更新都应该发生在记录簿更新之后。
I don't want a delay of the event triggering the read_model_update as the user will have to log back in immediately.
用户可能会立即重新登录，但这并不意味着您需要立即确认登录。
例如；通过写入模型，您刚刚发布了一堆新事件。获取您发布的最高事件的序列号，并将查询的那部分分派到读取模型；登录处理程序根据读取模型中的可用序列号检查序列号，如果模型需要另一个心跳来跟上，则停止。
（更有可能：在这种用例中，事件发布系统与来自客户端的后续请求之间存在竞争，您将安排一个读取模型来查询事件存储需要。所以你的延迟基本上是读取模型和记录系统之间的网络距离的函数，加上应用新事件所需的时间。实际上，来自客户端的请求充当事件消息，指示高水位线增加，然后模型发送查询以获取丢失的历史记录）。
另请注意推论——读取模型的不同部分具有不同的延迟要求。
CQRS 是一种 shell 游戏。仍然只有一个记录系统，即接受来自模型的写入的持久性存储。该存储针对写入进行了优化。读取模型可以附加到该存储（获取最新的可用数据，但由于数据采用 "write optimized" 形式而具有额外的处理延迟），或附加到该存储的投影（其中数据较旧，但已经针对具体阅读）。
我正在使用 CQRS（命令查询责任分离）模式实施一个测试项目。
我有几个问题。
我想在购买前检查用户购物车中某件商品在数据存储中的最新价格。因此，real_model（通过物化视图）价格将根据数据存储（产品 table）上的最新价格进行检查。如果价格之间存在差异，我想向用户显示警报。实现此目标的最佳方法是什么？
当用户更新他们的Email和Password时，是否仍然依赖于创建事件来更新DataStore（Event->EventStore->Service Bus->DataStore）还是直接更新Data Store？我不希望延迟触发 read_model_update 的事件，因为用户必须立即重新登录。
I want to check the latest price on the data store for an item on a users shopping cart just prior to purchasing... What is the best way to achieve this?
我怀疑 "best way to achieve this" 将在很大程度上取决于您的利益相关者希望提供给客户的购物体验。 IE - 什么时候应该锁定价格？例如，购物车中显示的价格可能是有时间限制的实盘。
但是请原谅那些细节...
一种方法是 运行 在发送命令之前对读取模型进行健全性检查。有一种常见模式（有效地）检查命令在给定读取模型的状态下是否有效，然后调度临时验证的命令以更新记录簿。您可以用一些延迟换取更低的故障率。
另一种可能是使用进程管理器；这个想法是 "placeOrder" 不是对模型的简单写入，而是生命周期的开始。因此，假设报价是您模型中的一个东西——当将商品放入购物车时，将生成报价（可能具有一些过期值）。当价格发生变化时，所有不同的报价都会更新。下订单时，处理程序会看到 placedOrder 事件，并尝试对报价调用 acceptQuote 方法；如果报价仍然有效，则生成的事件会将订单流程推进到下一个状态。如果引用不再有效，则生成不同的事件，或者命令被拒绝，最终超时表明可能存在问题....
（您可以尝试对产品本身做一些类似的事情，但由于争用问题，效果不佳；唯一知道您正在使用 the 的方法对象的最新状态是记录簿接受对其的写入。）
Udi Dahan 的 Race Conditions Don't Exist 评论可能会有用。
When the User updates their Email and Password should it still rely on creating events to update the DataStore (Event->EventStore->Service Bus->DataStore) or directly update the Data Store?
没有直接更新 -- 所有对读取模型的更新都应该发生在记录簿更新之后。
I don't want a delay of the event triggering the read_model_update as the user will have to log back in immediately.
用户可能会立即重新登录，但这并不意味着您需要立即确认登录。
例如；通过写入模型，您刚刚发布了一堆新事件。获取您发布的最高事件的序列号，并将查询的那部分分派到读取模型；登录处理程序根据读取模型中的可用序列号检查序列号，如果模型需要另一个心跳来跟上，则停止。
（更有可能：在这种用例中，事件发布系统与来自客户端的后续请求之间存在竞争，您将安排一个读取模型来查询事件存储需要。所以你的延迟基本上是读取模型和记录系统之间的网络距离的函数，加上应用新事件所需的时间。实际上，来自客户端的请求充当事件消息，指示高水位线增加，然后模型发送查询以获取丢失的历史记录）。
另请注意推论——读取模型的不同部分具有不同的延迟要求。
CQRS 是一种 shell 游戏。仍然只有一个记录系统，即接受来自模型的写入的持久性存储。该存储针对写入进行了优化。读取模型可以附加到该存储（获取最新的可用数据，但由于数据采用 "write optimized" 形式而具有额外的处理延迟），或附加到该存储的投影（其中数据较旧，但已经针对具体阅读）。