ScriptedFilterRecord
Описание
Этот процессор предоставляет возможность фильтровать записи из файлов потока с использованием пользовательского скрипта. Каждая запись будет оценена скриптом, который должен возвращать логическое значение. Записи с результатом "true" будут направлены в связь "matching" группами. Другие записи будут отфильтрованы.
Теги
record, filter, script, groovy
Свойства
| Название | Описание |
|---|---|
| Record Reader | Средство чтения записей для разбора входящего FlowFile на записи |
| Record Writer | Записывающее устройство для сериализации записей после их преобразования |
| Script Language | Язык, используемый для сценария |
| Script Body | Тело сценария для выполнения. Можно использовать только один из вариантов: «Файл сценария» или «Тело сценария» |
| Script File | Путь к файлу сценария для выполнения. Можно использовать только один из вариантов: «Фай л сценария» или «Тело сценария»This property requires exactly one file to be provided.. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Module Directory | Список путей к файлам и/или каталогам, содержащим модули, необходимые для выполнения сценария, через запятую.This property expects a comma-separated list of resources. Each of the resources may be of any of the following types: directory, file. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
Взаимосвязи
- success: Matching records of the original FlowFile will be routed to this relationship. If there are no matching records, no FlowFile will be routed here.
- failure: В случае возникновения какой-либо проблемы во время обработки входящего файла потока, входящий файл потока будет перенаправлен на это отношение.
- original: After successful procession, the incoming FlowFile will be transferred to this relationship. This happens regardless the number of filtered or remaining records.