NiFi урок№4 QueryRecord Выполняем SELECT к FLOWFILE

Мы начнем с представления четырех ключевых процессоров, которые часто используются в процессе работы с данными: GenerateFlowFile: Этот процессор генерирует тестовые данные или файлы, что позволяет нам создавать потоки данных для дальнейшей обработки. RouteOnAttribute: Данный процессор позволяет маршрутизировать поток данных в зависимости от значений атрибутов. Это полезный инструмент для фильтрации данных или направления их в нужное место для обработки. QueryRecord: С помощью этого процессора мы можем выполнять SQL-запросы к нашим данным, обрабатывать их и преобразовывать в нужный формат. Это отличный инструмент для работы с базами данных и другими структурированными данными. PutDatabaseRecord: Этот процессор используется для записи данных в базу данных после их обработки. Он обеспечивает простой способ интеграции вашего потока данных с различными хранилищами.