Можно ли читать данные потокового файла Nifi с помощью языка выражений nifi?

Question

В основном я хочу прочитать данные потокового файла и вызвать данные препроцессора другого процессора. пример: - kafka потребитель читает данные (процессор) ---> файл потока (идентификатор коллекции) -> Getmon go (процессор) получает данные из mon go на основе данных до процессора (идентификатор коллекции). Возможно ли это?

Answer 1

вы можете использовать процессор UpdateAttribute для обновления атрибутов для FlowFile с помощью языка выражений атрибутов и / или удаления атрибутов на основе регулярного выражения. Обработчик ExtractText, добавляющий пользовательский атрибут со значением, установленным к регулярному выражению "(. *)". создать новый атрибут со значением в качестве содержимого файла потока