Apache NiFi - взаимосвязь процессоров

В потоке данных Apache NiFi потоковые файлы перемещаются от одного процессора к другому через соединение, которое проверяется с использованием связи между процессорами. Каждый раз, когда создается соединение, разработчик выбирает одну или несколько взаимосвязей между этими процессорами.

Как вы можете видеть на изображении выше, флажки в черном прямоугольнике - это отношения. Если разработчик установит эти флажки, то потоковый файл завершится в этом конкретном процессоре, когда связь будет успешной или неудачной, или и тем, и другим.

Успех

Когда процессор успешно обрабатывает потоковый файл, такой как сохранение или выборка данных из любого источника данных, без получения какого-либо соединения, аутентификации или любой другой ошибки, тогда потоковый файл переходит в состояние успеха.

Неудача

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

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

Как вы можете видеть на изображении выше, соединение, отмеченное красным, имеет отношение сбоев, что означает, что все потоковые файлы с ошибками будут отправлены процессору слева, и, соответственно, все потоковые файлы без ошибок будут перенесены в соединение, отмеченное зеленым.

Давайте теперь перейдем к другим отношениям.