Можно ли установить событие created_at time с помощью Prooph?

Question

Я оцениваю, подходит ли 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:30.

Возможно ли это с Prooph? если нет, есть ли более правильный способ обработки таких данных с задержкой записи?

Answer 1

prooph / event-store работает с prooph / common, который представляет собой набор интерфейсов и базовых реализаций для обмена сообщениями. Вы можете реализовать интерфейсы для фабрики сообщений и конвертера сообщений так, как вам нужно. Но ваш случай уже рассмотрен, см. FQCNMessageFactory