NiFi: объединить атрибут с содержимым JSON потокового файла (без перезаписи всего потокового файла)

Question

У меня есть поток, который создает некоторые новые атрибуты / контент. Я хочу взять атрибут из потоковых файлов и добавить его в JSON-содержимое файла.

Я могу использовать AttributesToJSON, но это просто перезаписывает содержимое файла.

Образец моего потока здесь:

UpdateAttribute добавляет текущее время в список атрибутов, а затем AttributestoJSON добавляет атрибут к фактическому JSON, но он также перезаписывает все содержимое файла потока. Я пытался исправить это с помощью MergeRecord, но я не могу объединить два файла вместе (используя CurrentTime в качестве имени атрибута корреляции).

Что лучше сделать? MergeRecord только что выдал ошибку. (Также не уверен, как настроить RecordReader / Writer, потому что я хочу сохранить все в JSON).

Answer 1

Используйте UpdateRecord и добавьте свойство, где имя - это поле, которое вы хотите обновить, например "/ currentTime", а значение - это ссылка на язык выражений для атрибута, например $ {currentTime}, при условии, что вы установили currentTime в UpdateAttribute.