从 NiFi 中的纪元中提取日期

Question

我有一个 CSV 文件，其属性具有纪元值，例如“1517334599.906”。

我想通过 NiFi 将 Epoch 值转换/更新为 ISO 时间戳 'yyyy-MM-dd HH:mm:ss.SSS'。

该转换是为了让 Kibana 将该字段识别为时间戳。有没有办法做到这一点？如果有谁可以帮我配置一下吗？

Answer 1

使用 NiFi 的记录功能，您可以将 UpdateRecord 与 CsvReader 和 CsvWriter 结合使用。

请参阅表达式语言中的“format”函数，将纪元转换为日期字符串：

https://nifi.apache.org/docs/nifi-docs/html/expression-language-guide.html#format

在 UpdateRecord 中你会做类似的事情：

/eventDate = ${field.value:format("yyyy-MM-dd HH:mm:ss.SSS")} 

这表示获取 /eventDate 的值（将其更改为您的字段名称）并将该字段的值设置为右侧格式函数的结果。

我唯一不确定的是纪元是否可以有小数部分，如您的示例所示。我希望它能转换为一个整数。