В NiFi, как проверить, все ли файлы потоков на нескольких процессорах были обработаны или нет? - PullRequest
0 голосов
/ 01 мая 2019

Используя API отдыха Нифи, я пытаюсь остановить процессор «А» в группе процессоров.После этого мне нужно проверить, все ли потоковые файлы в группе процессоров обработаны или нет.

Как мне это сделать?

Сейчас я выполняю команду: http://localhost:9090/nifi-api/flow/process-groups/b6182fda-0169-1000-454a-c87dc744813c

Затем я проверяю счетчик bytesQueued в ответе JSON вышеприведенной команды.Однако я не уверен, что если один из моих процессоров обрабатывает большой файл, то как из ответа JSON проверить, что еще есть некоторые потоковые файлы, ожидающие полной обработки.Какие ключи JSON я должен проверить и сравнить?

...