Используя Apache Nifi, я создал поток, который читает Json-файл и разбивает его по строкам, чтобы проверить правильность содержимого. После этого у меня есть 2 выхода: 1 - для успешной строки и 2 - для неудачных, а выход - Json-файл.Apache Nifi - хранить строки в 1 файл
На данный момент все строки хранятся в отдельных файлах, но я хочу сохранить каждую «хорошую» строку в 1 файл и каждый «плохой» в другой.
Какой процессор следует использовать?
Процессор RouteText был разработан именно для того, что вы пытаетесь сделать. Он позволяет маршрутизировать строки текста на разные отношения на основе выражений, которые вы создаете. Он объединяет линии из каждого FlowFile для каждой связи.
Вы можете найти в документации к нему здесь: https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi.processors.standard.RouteText/index.html
Вы можете получить примерный шаблон (делает почти то, что вы хотели бы сделать) с помощью RouteText здесь: https://github.com/hortonworks-gallery/nifi-templates/blob/master/templates/SplitRouteMergeVsRouteText.xml