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

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

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

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

我知道流已被删除，因为当我使用这样的代码时引发了 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 无法清除当前活动的（最后一个）块，因此也存在问题。这是因为事件被写入这个块，所以它不能被关闭和重新创建（这就是清理工作的方式）。

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