​Корпус входа NiFi второй

Требования: случайным образом сгенерировать несколько наборов тестовых данных, выполнить регулярное сопоставление сгенерированных данных и вывести совпадающие данные во внешний файл. Вышеуказанное требует использования процессоров «GenerateFlowFile», «ReplaceText» и «PutFile».

1. Настройте процессор GenerateFlowFile.

Этот процессор может генерировать произвольные данные FlowFile или генерировать FlowFile с пользовательским содержимым. В основном используется для нагрузочного тестирования и тестирования данных, сгенерированных моделированием.

1. Перетащите «Процессор» и во всплывающем окне введите «GenerateFlowFile».

2. Настройте «GenerateFlowFile» для создания FlowFile.

Откройте конфигурацию «GenerateFlowFile» и найдите параметр «СВОЙСТВА» для настройки:

Параметры конфигурации «PROPERTIES» для «GenerateFileFile» объясняются следующим образом:

Расписание по умолчанию «GenerateFlowFile» будет выполняться непрерывно для генерации данных. Чтобы облегчить последующее тестирование, после настройки здесь конфигурации «СВОЙСТВА» вам также необходимо настроить «Расписание выполнения» в разделе «ПЛАНИРОВАНИЕ». , оно будет планироваться каждые 10 секунд. Цель: данные генерируются медленнее, что облегчает просмотр результатов позже.

2. Настройте процессор «ReplaceText».

Процессор «ReplaceText» заменит содержимое FlowFile, соответствующее регулярному выражению, и создаст новое содержимое FlowFile.

1. Перетащите «Процессор» и во всплывающем окне введите «GenerateFlowFile».

2. Настройте процессор «ReplaceText».

Получит данные «hello world», сгенерированные процессором «GenerateFlowFile», и заменит «world» на «nifi».

Параметры конфигурации «СВОЙСТВА» для «ReplaceText» объясняются следующим образом:

• Prepend
• Append
• Regex Replace
• Literal Replace
• Always Replace

Стратегия, определяющая способ замены содержимого FlowFile. Режим оценки Line-by-Line

• Line-by-Line
• Entire text

Выполните «стратегию замены» для каждой строки индивидуально (построчно); или буферизируйте весь файл в памяти (весь текст), а затем выполните для него «стратегию замены». Режим построчной оценки ALL

• All
• First-Line
• Last-Line
• Except-First-Line
• Except-Last-Line

В построчном «режиме оценки»: (ALL) По умолчанию используется «стратегия замены» для всех строк в FlowFile. (Первая линия): используйте «стратегию замены» только для первой линии. (Последняя строка): используйте «стратегию замены» только для последней строки. (кроме первой строки): используйте «стратегию замены», за исключением первой строки. (Except-Last-Line): используйте «стратегию замены», за исключением последней строки.

В приведенной выше таблице «Поиск Value”значение по умолчанию“(?s)(^.*$)”Объяснено ниже：

• (?s) означает включение однострочного режима.
• В (^.*$) ^ указывает на начало регулярного выражения.
• . означает соответствие любому символу, кроме символа новой строки.
• * означает совпадение предыдущего подвыражения 0 или более раз.
• $выражатьрегулярное выражение Заканчивать。

Доступные значения для «Стратегии замены» в таблице выше поясняются ниже:

• Prepend: вставьте значения замены в начало файла потока или в начало каждой строки (в зависимости от режима оценки). Если для параметра «Режим оценки» установлено значение «Построчно», значение будет добавлено в начало каждой строки, а если установлено значение «Весь текст», значение будет добавлено в начало всего текста.
• Добавить: вставить значения замены в конец файла потока или в конец каждой строки (в зависимости от режима оценки). Если для параметра «Режим оценки» установлено значение «Построчно», значение будет добавлено в начало каждой строки, если установлено значение «Весь текст», значение будет добавлено в начало всего текста.
• Regex Заменить: используйте «Замена». Value"Заменить всерегулярное выражениесоответствующее значение,"Замена Value"Можно цитироватьрегулярное Выражение Соответствующее значение указывается с помощью $1, $2 и т. д.
• Буквальная замена: если значение «Значение поиска» является значением поиска, используйте значение замены «Значение замены», чтобы заменить совпадение.
• Always Заменить: всегда заменяет всю строку или все содержимое FlowFile (в зависимости от «Режима» оценки" значение атрибута), поиск значений производиться не будет. При выборе этой стратегии "Поиск Атрибут Value» будет игнорироваться.

3. Настройте процессор «PutFile».

По поводу параметров создания и настройки процессора «PutFile» см. Случай 1. Конфигурация процессора «PutFile» задается непосредственно здесь, а заменяемый FlowFile записывается во внешний путь «/root/test/matchFile»:

​

4. Подключите каждый процессор и запустите тест.

При подключении процессора «ReplaceText» и процессора «PutFile» необходимо установить взаимосвязь конфигурации соединения. Когда процессор «ReplaceText» записывает успешно совпавшие данные в процессор «PutFile»:

​

Установите FlowFile для автоматического прекращения связи, когда обработчик «ReplaceText» не соответствует:

Полное соединение выглядит следующим образом:

После запуска процессора GenerateFlowFile:

При этом просмотрите данные в «Происхождении данных» следующим образом:

Запустите процессор «ReplaceText» и просмотрите обработанные данные:

Запустите процессор «PutFile», и соответствующие данные сгенерируются на каждом узле, соответствующем кластеру NiFi:

Посмотреть результаты данных: