我正在评估证据是否适合这个项目。我阅读了这些文档,但是它们没有涵盖这个案例,我不知道如何像这样使用它,或者我想要做的事情在事件来源方面是否有意义。
我有一个系统,每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"},
]如果我正在处理这个实时事件,那么将在10:23发送一个"OFF“事件。
然而,数据被延迟了,但是我仍然希望存储事件,就像它发生在10:23一样,尽管我可能会将它发送到10:30的事件存储中。
这和普罗帕有可能吗?如果没有,是否有更恰当的方法来处理这样的延迟记录数据?
发布于 2021-11-07 15:57:10
prooph/event-store与prooph/prooph一起工作,它是一组用于消息传递的接口和基本实现。您可以按照需要实现消息工厂和消息转换器的接口。但是您的案例已经涵盖了,请参阅FQCNMessageFactory
https://stackoverflow.com/questions/69861338
复制相似问题