Apache NiFi - Очереди

Соединение потока данных Apache NiFi имеет систему очередей для обработки большого количества поступающих данных. Эти очереди могут обрабатывать очень большое количество файлов Flow, чтобы процессор мог обрабатывать их последовательно.

Очередь на изображении выше имеет 1 потоковый файл, переданный через отношения успеха. Пользователь может проверить потоковый файл, выбравList queueвариант в раскрывающемся списке. В случае перегрузки или ошибки пользователь также может очистить очередь, выбравempty queue вариант, а затем пользователь может перезапустить поток, чтобы снова получить эти файлы в потоке данных.

Список потоковых файлов в очереди состоит из позиции, UUID, имени файла, размера файла, длительности очереди и продолжительности происхождения. Пользователь может увидеть все атрибуты и содержимое потокового файла, щелкнув значок информации, присутствующий в первом столбце списка потоковых файлов.