NiFi 日期格式 - 将小时添加到记录中的时间戳并覆盖

问题描述

我想在 NiFi 记录中更改日期时间(时间戳列),但我无法覆盖现有值的新值,所以我不得不创建新变量。 有没有办法覆盖现有值,或者我可以使用 updateAttribute 处理器等吗?

我在下面解释了管道。 输入 Json=> UPDATE RECORD PROCESSOR => 输出 Json

输入:

{"machine":"E117","timestamp":"2020-12-30 12:27:47.047"}

更新记录:

**Record Reader:**                 JsonTreeReader
**Record Writer:**                 JsonRecordSetWriter
**Replacement Value Strategy:**    Record Path Value             
**/date:**                         format(toDate(/timestamp,"yyyy-MM-dd HH:mm:ss.SSS","Europe/Istanbul"),"yyyy-MM-dd'T'HH:mm:ss.SSS",'+00:00')

输出

{"machine":"E117","timestamp":"2020-12-30 12:27:47.047","date":"2020-12-30T09:27:47.047"}

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)