Apache NiFi - Relacja procesorów

W przepływie danych Apache NiFi pliki przepływu są przenoszone z jednego procesora do drugiego przez połączenie, które jest weryfikowane przy użyciu relacji między procesorami. Za każdym razem, gdy tworzone jest połączenie, programista wybiera jedną lub więcej relacji między tymi procesorami.

Jak widać na powyższym obrazku, pola wyboru w czarnym prostokącie to relacje. Jeśli programista zaznaczy te pola wyboru, plik przepływu zakończy się w tym konkretnym procesorze, gdy relacja zakończy się sukcesem lub niepowodzeniem lub obu.

Sukces

Gdy procesor pomyślnie przetwarza plik przepływu, na przykład przechowuje lub pobiera dane z dowolnego źródła danych, bez uzyskiwania połączenia, uwierzytelniania lub innego błędu, plik przepływowy przechodzi do relacji sukcesu.

Niepowodzenie

Gdy procesor nie jest w stanie przetworzyć pliku przepływu bez błędów, takich jak błąd uwierzytelniania lub problem z połączeniem, itp., Plik przepływu przechodzi do relacji niepowodzenia.

Programista może również przenieść pliki przepływu do innych procesorów za pomocą połączeń. Deweloper może wybrać, a także zrównoważyć obciążenie, ale równoważenie obciążenia zostało właśnie wydane w wersji 1.8, co nie zostanie omówione w tym samouczku.

Jak widać na powyższym obrazku połączenie zaznaczone na czerwono ma relację awarii, co oznacza, że ​​wszystkie pliki flowfile z błędami trafią do procesora po lewej stronie i odpowiednio wszystkie pliki flowfile bez błędów zostaną przeniesione na połączenie zaznaczone na zielono.

Przejdźmy teraz do innych relacji.

comms.failure

Ta relacja jest spełniona, gdy plik Flowfile nie mógł zostać pobrany ze zdalnego serwera z powodu awarii komunikacji.

nie znaleziono

Każdy plik Flowfile, dla którego otrzymamy komunikat „Nie znaleziono” ze zdalnego serwera, zostanie przeniesiony do not.found związek.

pozwolenie.denied

Gdy NiFi nie będzie w stanie pobrać pliku przepływu ze zdalnego serwera z powodu niewystarczających uprawnień, przejdzie przez tę relację.