如何在asp.net核心应用程序中使投影更快？

Question

我有两个数据库的web应用程序：

• EventStoreDB -为活动
• PostgreSQL + Marten -用于预测

对于订阅和将数据从事件存储添加到postgres，我使用这个示例示例，但是，当我进行创建操作并获得成功结果时，接下来我尝试从postgres加载新对象，postgres没有我的新对象。

如何使“从事件存储应用到postgres的事件更快或更同步”？

Answer 1

根据定义，事件源系统在存储在事件存储中的事件之间有一个时间差，并且它被投影到读取模型中。除非在将事件提交到存储区时，将事件同步应用到内存中的读取模型，否则延迟总是存在的。但是，这种方法将限制您将服务作为单个实例运行，否则，您无法确定内存中的状态是同步的。有一些技术可以解决这一问题，但它们相当复杂。

由于您没有描述需要立即获得读取的模型数据，所以很难给出具体的建议，但我有一些建议。

1. 如果UI需要它，而UI需要新的实体状态，则可以返回实体状态作为命令处理结果，因为您已经有了它。然后，UI可以立即显示状态，而无需执行任何查询。
2. 相同的场景，但是您将新事件的集合返回给UI。如果UI位是用React和Flux之类的东西构建的，那么它们很可能已经有了“事件源”(这就是Flux的本质)，并且通过它们的还原程序应用这些事件，它们可以更新UI而无需查询读取模型。
3. 如果您知道什么读取模型需要同步(我不能说您有多少)，您可以将事件提交位置作为元数据属性或仅仅作为文档属性传播到读取模型。然后，您可以保持API调用(基本上是等待)，直到read模型update位置属性等于或超过提交位置。缺点是，您只能对特定的读取模型执行此操作，因此您的命令处理程序需要对读取侧了解太多。
4. 类似于(3)，但您检查检查点存储位置。如果没有使用批处理优化检查点存储，它将很快通过最后一个事件提交位置，然后将200 OK返回给调用方。它比(3)简单一点，因为它只关心订阅检查点，而不是单个读取模型，但是您需要访问检查点存储。
5. UI在获得命令处理后也可以这样做，您需要返回最后一个事件的提交位置，然后进行查询和等待。

我已经看到以上所有的工作在生产中，但我喜欢的解决方案是(1)和(2)。

要使其中任何一个工作，您的命令服务需要像我的在意外事件中完成那样将复杂的结果返回给调用者(API或更多)。