我的任务是创建一个事件流,我有一个自动轮询器(设置为 10 分钟间隔)来检索在过去 10 分钟内更改的所有实体。
现在,业务逻辑规定我们仅在实体中特定字段发生更改时创建新的更新事件。由于我们没有关于特定字段更改的粒度(我们所知道的是某些更改),因此我必须创建某种执行以下操作的微分器方法:
- 获取之前的实体状态
- 将之前的状态与最新的状态进行比较(即差异)
- 如果至少有一个字段被业务逻辑确定为重要,则创建更新事件
- 如果更新事件已创建,则将之前的实体状态替换为最新的
考虑到这个架构问题,是否有已知的模式或模式集,或指导如何构建这种类型的系统?