如何将 NiFi 处理器的写入属性发送到下一个处理器?

How can I send the write attribute of a NiFi processor to next processor?

我正在使用 GetHDFSEvents 处理器知道 hdfs.inotify.event.path。当在 hdfs 中创建新文件时,我需要得到路径通知。如何将属性 hdfs.inotify.event.path 传递给下一个处理器以根据路径

执行 shell 脚本

如果您只想收到通知,请使用 ListHDFS 和路径属性而不是 GetHDFS。

尝试使用 ListHDFS 处理器并使用 Fetchhdfs 或 ExecuteStream 命令处理器。使用表达式语言 ${path}/${filename}