Как инициализировать процессор через NIFI API

Question

, пожалуйста, помогите!

Я использую процессор ListSFTP для получения и обработки файлов.В первом исполнении процессор принимает файлы нормально, но при запуске процессора во второй раз это не так.Я знаю, что это правильное поведение для этого процессора.Есть ли способ запустить и инициализировать процессор через NIFI API таким образом, чтобы он снова принимал файлы?Мне нужен этот подход, потому что мне нужно провести тестирование.

Спасибо!

Answer 1

Да, это ожидаемое поведение (в противном случае при каждой операции со списком процессор возвращал один и тот же список файлов).Чтобы использовать это для тестирования, вы можете щелкнуть правой кнопкой мыши на остановленном процессоре и выбрать Просмотр состояния , а затем нажать Очистить в появившемся диалоговом окне.В следующий раз, когда процессор запустится, он снова выведет список всех файлов (и соответствующих шаблонов фильтров).Эти действия также доступны через REST API .

Answer 2

Это решение:

http://localhost:8081/nifi-api/processors/{id_processor}/state/clear-requests

Спасибо!