如何使用NiFi表达式语言将时间戳转换为日期格式HDFS文件夹路径？

刚好之前处理过类似的NiFi分流场景，给你两个实用的原生解决方案，不用额外加脚本或者复杂组件：

首先先纠正你之前EvaluateJsonPath的小配置问题：在EvaluateJsonPath里，属性的值应该用JsonPath表达式（比如$.creationDate）来提取JSON字段，而不是${creationDate}（这是NiFi的表达式语言，EvaluateJsonPath不认这个），并且要把处理器的Destination设为flowfile-attribute，这样提取的时间戳才会变成FlowFile的属性供后续使用。

方法1：用NiFi表达式语言快速处理（最推荐） #

如果你的时间戳格式固定是yyyy-MM-dd'T'HH:mm:ss.SSSSSSXXX这种，有两种简单方式：

方式A：字符串截取（最快） #

1. 在EvaluateJsonPath里新增属性rawCreationDate，值填$.creationDate，提取完整时间戳到FlowFile属性。
2. 直接在PutHDFS的Directory配置里写：

   /${rawCreationDate:substringBefore('T')}
   

   这个表达式会直接截取T字符之前的部分，也就是你要的2019-01-19格式日期。

方式B：日期格式转换（更鲁棒） #

如果担心时间戳格式有微小变化（比如时区符号不同），用日期转换函数更稳妥：

1. 同样用EvaluateJsonPath提取rawCreationDate属性。
2. PutHDFS的Directory配置改成：

   /${rawCreationDate:toDate('yyyy-MM-dd'T'HH:mm:ss.SSSSSSXXX'):format('yyyy-MM-dd')}
   

   这里toDate()的参数是你当前时间戳的格式，format()是你要输出的目标日期格式，适配性更强。

方法2：正则表达式提取（适合复杂格式场景） #

如果时间戳格式不固定，但日期部分始终是开头的yyyy-MM-dd，可以用正则来精准提取：

1. 先通过EvaluateJsonPath提取rawCreationDate属性。
2. 添加一个UpdateAttribute处理器，新增属性targetDate，值设为：

   ${rawCreationDate:replaceFirst('^(\\d{4}-\\d{2}-\\d{2}).*$', '$1')}
   

   这个正则会匹配开头的10位日期部分，把整个字符串替换成这个日期片段。
3. 最后在PutHDFS的Directory里写/${targetDate}就行。

调试小技巧 #

可以在EvaluateJsonPath之后加一个LogAttribute处理器，把FlowFile的属性打印出来，确认提取和转换后的日期值是否正确，方便排查问题。

内容的提问来源于stack exchange，提问作者lengthy_preamble