Цель проекта — быть точной копией среды NiFi для тестирования и отладки скриптов на Groovy, которые должны выполняться в процессорах ExecuteScript и ExecuteGroovyScript.
Отредактируйте скрипт на Groovy в файл /nifi-mock-processors/src/main/resources/script.groovy.
В каталоге /nifi-mock-processors/src/main/resources/source расположите файлы для обработки.
Для примера даны два файла flowfile1.in и flowfile2.in это файлы с входящими данными.
flowfile1.in.attributes и flowfile2.in.attributes файлы с атрибутами флоуфайла в формате JSON где перечеслены пары ключ - значение.
Также есть файл с атрибутами для всех файлов default.attributes и файл с динамическими свойствами процессора dynamic-properties.json.
Файлы с атрибутами могут отсутсвовать.
Запустите тест testProcessor() из пакета com.tinkoff.processors.mock.
Если запустить в режиме debug, то можно пользоваться точками останова в groovy скрипте.
Пример:
Проверьте вывод в каталоге /nifi-mock-processors/target/out.
В зависимости от результата либо в папке success, либо в failure появится выходной файл.
Если версия вашего JDK выше 1.8, то:
- Откройте конфигурацию запуска для
MockProcessorTest. - Найдите строку с параметрами виртуальной машины (VM options).
- Добавьте
"--add-opens java.base/java.lang=ALL-UNNAMED".