获取 NEventStore 头部修订版

Question

我有一个新的 ES 流，里面已经有五十万个事件（还没有快照......我知道，我正在到达那里）和一个简单的客户端，ATM 只是附加（甚至更多）事件。

NEventStore.OpenStream(int.MinValue, int.MaxValue)最初打开流需要很长时间;之后我存储最后一个修订版，从那时起，只有NEventStore.OpenStream(lastRevision, int.MaxValue)再次追加。问题仅在初始启动时。

NEventStore中是否有一种机制可以简单地附加而不打开，或者在不打开整个流的情况下确定头部修订，以便我可以从最后一个版本打开并附加。当然，我也可以直接转到数据库并查询，但这具有我认为我不需要的依赖项。

Answer 1

您已经提到了一个可能的解决方案：快照。

此示例从最新快照打开流，并在提交事件后添加新快照。

// Get the latest snapshot
var latestSnapshot = _eventStore.Advanced.GetSnapshot(streamId, int.MaxValue);            
// Open the stream from the snapshot if there is one, otherwise open the stream as normal
using (var stream = latestSnapshot == null ? 
    _eventStore.OpenStream(streamId) : 
    _eventStore.OpenStream(latestSnapshot, int.MaxValue))
{
    // Add events and commit
    stream.Add(new EventMessage());
    stream.CommitChanges(Guid.NewGuid());
    // Add a new snapshot (with no payload)
    _eventStore.Advanced.AddSnapshot(
        new Snapshot(streamId, stream.StreamRevision, string.Empty));
}      

可能没有必要经常添加新快照。这只是一个展示快照如何工作的示例。