事件存储 - 从投影中过滤掉任何已删除的流

问题描述

删除了一些流,但在投影开始时我仍然收到这些流。

有没有办法从投影中过滤掉任何已删除的流?

我知道流已被删除,因为当我使用这样的代码时引发了 var events = _eventStoreConnection.ReadStreamAsync( Direction.Forwards,e.Event.EventStreamId,StreamPosition.Start); await foreach (var @event in events) { } 异常:

{{1}}

解决方法

您的问题需要比您提供的内容更多的上下文。

稍微澄清一下。投影不存储流。投影也不存储事件。投影是恰好向流发送事件的计算。

您似乎依赖于 $streams 或类似的东西,链接 来自您删除的流的事件。区别很重要,因为存储在像 $streams 这样的流中的实际上是指向属于不同流的事件的链接。因此,当流被删除时,指向其事件的链接不会被删除。

$streams 的情况下,存储的是指向每个流第一个事件的链接。链接是具有遵循此模式 {version_number}@{stream_name}$> 事件类型的有效负载的事件。

在 EventStoreDB 中,您不能像删除 SQL 数据库中的行那样删除事件,但可以删除流(如果有帮助,您可以将其视为表)

,

您从订阅中的已删除流接收事件的原因是,正如 Yo 所写,当您删除流时,事件不会删除

如果您订阅了常规流或投影流(如类别),则不应从已删除的流中获取事件。订阅包含链接的流时,如类别流,您需要将 resolveLinkTos 设置为 true

但是,如果您订阅 $all,如果您从头开始,您从已删除的流中获取事件。这是因为从 $all 读取时,我们直接从事件日志中读取,事件仍然存在。这个问题是已知的,我们计划解决它,但现在就是这样。这不会导致很多问题,因为对 $all 的订阅通常以实时模式运行,在这种情况下与删除无关。但是,从头开始阅读时,您确实遇到了这个问题。

当您运行清理时,已删除流的事件、截断的流以及根据流 TTL 和最大计数过期的事件都将被删除。由于 EventStoreDB 无法清除当前活动的(最后一个)块,因此也存在问题。这是因为事件被写入这个块,所以它不能被关闭和重新创建(这就是清理工作的方式)。

当您有小卷(开发、测试)并且活动块仍然是唯一的块时,就会出现清理问题,因此它永远不会被清理。