从 NiFi 中的纪元中提取日期

Extract Date from epoch in NiFi

我有一个 CSV 文件,其属性的纪元值类似于“1517334599.906”。

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

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

使用 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 的值(将其更改为您的字段名称)并将该字段的值设置为右侧格式函数的结果。

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