获取 NEventStore head 修订版
Get NEventStore head revision
我有一个新的 ES 流,其中已经有 50 万个事件(还没有快照......我知道,我已经到了)和一个 atm 仅附加的简单客户端(甚至更多) 事件。
NEventStore.OpenStream(int.MinValue, int.MaxValue)
最初打开流需要很长时间;之后,我存储最后一个修订版,然后仅 NEventStore.OpenStream(lastRevision, int.MaxValue)
再次追加。问题仅在初始启动时。
NEventStore
中是否有一种机制可以在不打开的情况下简单地追加,或者在不打开整个流的情况下确定主要版本,这样我就可以从上一个版本打开并追加。当然我也可以直接进入数据库并查询,但我认为我不应该需要这种依赖性。
您已经提到了一个可能的解决方案:快照。
此示例从最新快照打开流并在事件提交后添加新快照。
// 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));
}
可能没有必要经常添加新快照。这只是展示快照如何工作的示例。
我有一个新的 ES 流,其中已经有 50 万个事件(还没有快照......我知道,我已经到了)和一个 atm 仅附加的简单客户端(甚至更多) 事件。
NEventStore.OpenStream(int.MinValue, int.MaxValue)
最初打开流需要很长时间;之后,我存储最后一个修订版,然后仅 NEventStore.OpenStream(lastRevision, int.MaxValue)
再次追加。问题仅在初始启动时。
NEventStore
中是否有一种机制可以在不打开的情况下简单地追加,或者在不打开整个流的情况下确定主要版本,这样我就可以从上一个版本打开并追加。当然我也可以直接进入数据库并查询,但我认为我不应该需要这种依赖性。
您已经提到了一个可能的解决方案:快照。
此示例从最新快照打开流并在事件提交后添加新快照。
// 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));
}
可能没有必要经常添加新快照。这只是展示快照如何工作的示例。