NiFi после вызова HTTP API, как получить оригинальный файл потока перед вызовом HTTP API

Question

У меня есть приведенная ниже последовательность для вызова rest API.

Генерация процессора FLowfile -> Процессор jsonpath -> Процессор замены текста (для создания данных после записи) ---> InvokeHTTP ---> Процессор XPATHдля атрибута ---> исходный файл потока, который генерируется файлом потока создания.

SO, после замены текстового процессора исходные данные будут заменены новыми данными.Итак, как я могу получить исходные данные и использовать атрибуты, созданные после вызова API.

Answer 1

в том месте, где у вас есть оригинальный файл, вставьте UpdateAttribute с оценкой какого-то уникального атрибута.

, например MyUID = ${UUID()}

соединение success после UpdateAttribute должно перейти в поток подготовки для вызова http, а копия этого соединения должна перейти к MergeContent, который должен объединитьисходное и оцененное содержимое и атрибуты.

поток:

UUID & split:

объединить содержание:

Answer 2

Вы можете сохранить исходный файл потока с прямым выходным отношением из GenerateFlowFile и объединить файлы потока позже с MergeContent в режиме Дефрагментировать и Сохранить все уникальные атрибуты , илиесли исходное содержимое потокового файла достаточно мало, вы можете переместить его в атрибут перед изменением содержимого потокового файла, а затем рекомбинировать их после получения новых данных с помощью Update Attribute / ReplaceText.