Apache NiFi - содержание процесса в CSV S3Object

Question

Я пытаюсь обработать CSV, хранящийся в S3 Bucket с Apache NiFi.

Для этой цели я использую следующий поток:

Дело в том, что мне нужно заменить какой-то текст из CSV файл, но я получаю в качестве вывода FetchS3Object файл, а не текст.

Как получить доступ к тексту объекта S3Object?

Спасибо!

Answer 1

Наконец я нашел способ исправить проблему.

Использование процессора SplitText после FetchS3Object позволяет разбивать строку на строку (count = 1) и обрабатывать каждую строку после этого процессора.