1

我正在评估 Proof 是否适合这个项目。我通读了文档，但它们没有涵盖这种情况，我不确定如何像这样使用它，或者我想做的事情是否对事件溯源有意义。

我有一个系统每 5 到 10 分钟获取一次数据，但在该数据中是在该时间内获取的一系列指标。（简化示例）

[
  {"time": "2021-11-08 10:21:00", "setting": "on"}, 
  {"time": "2021-11-08 10:22:00", "setting": "on"}, 
  {"time": "2021-11-08 10:23:00", "setting": "off"},
  {"time": "2021-11-08 10:24:00", "setting": "off"},
  {"time": "2021-11-08 10:25:00", "setting": "off"},
]

如果我正在处理这个实时，一个“OFF”事件将被发送到10:23。

然而数据被延迟了，但我仍然想将事件存储为好像它发生在10:23，即使我可能将它发送到事件存储中10:30。

Prooph可以做到这一点吗？如果没有，是否有更合适的方法来处理这样的记录延迟数据？

4

1 回答 1

2

prooph/event-store 与 prooph/common 一起使用，prooph/common 是一组用于消息传递的接口和基本实现。您可以按照您需要的方式自由地实现消息工厂和消息转换器的接口。但是您的情况已经涵盖，请参阅FQCNMessageFactory

于 2021-11-07T15:57:10.883 回答