微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

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

如何解决比较 NiFi 中不同流的 2 个日期

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

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

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

enter image description here

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

enter image description here

enter image description here

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

解决方法

使用以下组合:

PutDistributedMapCache 和 FetchDistributedMapCache

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。