Apache NiFi - Warteschlangen
Die Apache NiFi-Datenflussverbindung verfügt über ein Warteschlangensystem, um den großen Datenfluss zu bewältigen. Diese Warteschlangen können sehr viele FlowFiles verarbeiten, damit der Prozessor sie seriell verarbeiten kann.
In der Warteschlange im obigen Bild wird 1 Flussdatei durch eine Erfolgsbeziehung übertragen. Ein Benutzer kann die Flussdatei überprüfen, indem er die Option auswähltList queueOption in der Dropdown-Liste. Im Falle einer Überlastung oder eines Fehlers kann ein Benutzer die Warteschlange auch durch Auswahl von löschenempty queue Option und dann kann der Benutzer den Fluss neu starten, um diese Dateien wieder in den Datenfluss zu bekommen.
Die Liste der Flussdateien in einer Warteschlange besteht aus Position, UUID, Dateiname, Dateigröße, Warteschlangendauer und Abstammungsdauer. Ein Benutzer kann alle Attribute und Inhalte einer Flussdatei anzeigen, indem er auf das Infosymbol in der ersten Spalte der Flussdateiliste klickt.