如何通过事件源和CQRS处理投影错误？

Question

我想使用事件源和CQRS，所以我需要预测（我希望我使用的是正确的术语）来更新我的查询数据库。如何处理数据库错误？

例如，我的一个查询缓存数据库不可用，但我已经更新了其他数据库。因此，当snyc回到业务中时，不可用的数据库将不会与其他数据库一起在snyc中。它如何知道它必须运行例如事件存储中的最后10个域事件？我想我必须存储有关数据库当前状态的信息，但是如果数据库状态存储失败怎么办？有什么想法，最佳实践如何解决这类问题？

Answer 1

在任何一种情况下，您都必须告诉消息传递总线处理失败，它应该稍后重新传递事件，希望届时数据库将恢复联机。这就是为什么我们使用带有“至少一次”传递保证的消息总线系统的本质原因。

当然，对于事务性查询数据库，还应该回滚事务。如果查询数据库不支持事务，则必须在应用程序端确保更新是幂等的--也就是说，如果您的事件是在下一次交付尝试时到达的，则必须设计投影代码和/或数据库，以便对事件的重复处理不会损害数据库的状态。这有时是微不足道的（例如，当事件导致投影中的人名发生改变时），但通常不是那么微不足道（例如，当投影只是增加视图计数时）。但当您使用非事务性数据库时，这就是您需要支付的费用。