Apache NiFi - kolejki

Połączenie przepływu danych Apache NiFi posiada system kolejkowania, który obsługuje napływ dużej ilości danych. Te kolejki mogą obsługiwać bardzo dużą liczbę plików FlowFiles, aby umożliwić procesorowi ich szeregowe przetwarzanie.

Kolejka na powyższym obrazku ma 1 plik przepływu przesłany przez relację sukcesu. Użytkownik może sprawdzić plik przepływu, wybierając plikList queueopcja na liście rozwijanej. W przypadku przeciążenia lub błędu użytkownik może również wyczyścić kolejkę, wybierając plikempty queue opcja, a następnie użytkownik może ponownie uruchomić przepływ, aby ponownie pobrać te pliki w przepływie danych.

Lista plików przepływu w kolejce składa się z pozycji, identyfikatora UUID, nazwy pliku, rozmiaru pliku, czasu trwania kolejki i czasu trwania linii. Użytkownik może zobaczyć wszystkie atrybuty i zawartość pliku przepływowego, klikając ikonę informacji znajdującą się w pierwszej kolumnie listy plików przepływowych.