【发布时间】:2020-12-07 16:38:59
【问题描述】:
我正在使用带有oracle persistence 的 Akka.net。
现在我需要根据我的聚合事件创建一个投影,并且我需要事件发生的时间戳。
很遗憾,我没有将此属性添加到事件中。
但是,查看持久化使用的 EventJournal 表,有一个时间戳列
但我似乎无法在 PersistentQuery 流中访问它:
Source<EventEnvelope, NotUsed> stream =
PersistenceQuery
.Get(_system)
.ReadJournalFor<SqlReadJournal>(SqlReadJournal.Identifier)
.EventsByTag(_myTag, 0L);
因为EventEnvelope 里面没有这个属性。
有人知道是否有办法获取我的投影的时间戳吗?
【问题讨论】:
-
Scala 中的等效类 (
akka.persistence.query.EventEnvelope) 确实有timestamp字段,所以我猜你运气不好,需要向 .net 的 akka 维护者提出问题跨度>