ScriptedValidateRecord
Описание
Этот процессор предоставляет возможность проверять записи во входных файлах потока с использованием пользовательского скрипта. Скрипт должен получать запись в качестве аргумента и возвращать логическое значение. На основе этого результата процессор категоризирует записи как "допустимые" или "недопустимые" и направляет их в соответствующую связь группами. Кроме того, исходный файл потока будет направлен в связь "original", а в случае неудачной обработки — в связь "failed".
Теги
record, validate, 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 (будет оцениваться только с использованием переменных среды) |
Взаимосвязи
- valid: FlowFile containing the valid records from the incoming FlowFile will be routed to this relationship. If there are no valid records, no FlowFile will be routed to this Relationship.
- invalid: FlowFile containing the invalid records from the incoming FlowFile will be routed to this relationship. If there are no invalid records, no FlowFile will be routed to this Relationship.
- failure: В случае возникновения проблем при обработке входящего файла потока входящий файл потока будет перенаправлен в это отношение.
- original: After successful procession, the incoming FlowFile will be transferred to this relationship. This happens regardless the FlowFiles might routed to "valid" and "invalid" relationships.