Я хотел изменить содержимое потоковых файлов таким образом, чтобы некоторые части исходного содержимого были заменены моими собственными строковыми значениями во всем содержимом. Прикрепленный файл моего образца потока в формате Json. Я хотел заменить имена полей, такие как «bulletinGroupName», «bulletinSourceName» и т. Д., На мои собственные значения, такие как «ProcessorGroupName», «Processor Name» соответственно. Я пытаюсь использовать ReplaceText Processor, но не могу получить желаемый результат. Прилагается моя часть потока nifi. Кроме того, я хотел знать, как получить новые строки в одном файле потока. Я хотел записать измененное содержимое файла потока в другой файл (текстовый формат тоже подойдет) с новыми строками между каждым элементом массива файла Json. Пример ожидаемого выходного файла и настроенный процессор также прилагаются. Посмотри. Ценю вашу помощь.
Файл образца потока Ожидаемый выходной файл Поток Nifi Конфигурация процессора