比较 NiFi 中不同流的 2 个日期

问题描述

我想比较和计算来自不同流程的 2 个日期之间经过的时间。

假设您每分钟收到一个带有时间戳的 json，并且您想计算实际 csv 与前一个 csv 之间的差异。

我所做的是： 使用 EvaluateJsonPath 获取时间戳

之后，使用 UpdateAttribute 尝试存储时间戳并针对另一个进行评估

我不知道为什么这不起作用。

解决方法

使用以下组合：

PutDistributedMapCache 和 FetchDistributedMapCache