У меня есть поток NIFI для чтения файлов с сервера и передачи в Kinesis Stream.Я хочу прочитать имя файла и добавить его как часть файлов / записей, отправляемых процессору putKinesis.
Поток NIFI: ListSFTP - FetchSFTP-- UpdateAttribute - PutKineses Ожидается: извлечение имен файлов, считанных с сервера sftp идобавьте его к записям, которые отправляются в PutKinesis, чтобы при получении сообщений у пользователя была возможность отследить сообщение, к какому файлу он принадлежит.
Я хотел бы добавить имя файла к данным (body) который отправляется в поток Kinesis.Как этого добиться?