Как обрабатывать файлы с тем же именем в Apache NiFi?

Question

Я изучаю NiFi, и я работаю над потоком, где я получаю файлы с использованием GetFile, а затем выполняю некоторый процесс, а затем сохраняю их в HDFS с использованием процессора PutHDFS. Дело в том, что, скорее всего, я получу файлы с тем же именем. Например, я могу получить файл каждые 30 минут, и файл, который создается каждые 30 минут, будет иметь то же имя.

Теперь, когда я помещаю этот файл в HDFS, я получаю «Файл с тем же именем уже существует». Как мне это преодолеть? Есть ли способ изменить имя файла при запуске?

Answer 1

Это очень простой способ. Я просто должен использовать процессор UpdateAttribute, чтобы изменить имя файла. Например: вы можете добавить timestamp к имени файла.

В UpdateProcessor добавьте свойство filename и его значение ${filename}.${now()}