Einführungs-Tutorial

Durch das Auswählen eines Prozessors werden die Einstellungen auf der rechten Seite im Konfigurationsbereich dargestellt. Jeder Prozessor besitzt zwei Einstellungsbereiche:

Für unser Beispiel wollen wir beim GenerateFlowFile-Prozessor zunächst den Properties-Tab genauer begutachten. Hier würde bei diesem spezifischen Prozessor die Möglichkeit bestehen, FlowFiles mit zufälligen oder mit definierten Daten zu generieren. In diesem Fall soll der generierte Text für den FlowFile nicht zufällig, sondern fest definiert sein. Um diese Einstellungsmöglichkeit anzeigen zu lassen, können über den Stern-Button am oberen Ende des Konfigurationsbereichs die Eingabefelder eingeblendet werden, die keine Pflichtfelder sind. Dadurch öffnet sich die Option einen Custom Text zu definieren. Hier kann ein beliebiger Text oder ein beliebiges Daten-Format als Inhalt für den FlowFile eingefügt werden. Um das Beispiel an dieser Stelle simpel zu halten, kann hier zunächst ein String eingefügt werden:

Die Konfiguration sollte dadurch wie in der folgenden Abbildung aussehen.

Zusätzlich soll im Settings-Tab die Run Schedule auf "30 Sekunden" eingestellt werden, damit ein gewisser Zeitabstand zwischen den generierten Daten vorhanden ist.

Dadurch werden nun alle 30 Sekunden ein Flowfile mit dem festgelegten String erzeugt.

Die Einstellungen des Prozessors werden automatisch gespeichert, sobald man zum nächsten Prozessor wechselt oder in den Diagramm-Bereich klickt.
Es ist allerdings auch möglich, die Einstellungen manuell durch den jeweiligen Button in der Toolbar zu speichern.

Die Konfiguration des CountText-Prozessors verläuft ähnlich, wobei keine allgemeinen Settings verändert werden müssen. In den individuellen Prozessor-Properties kann bei diesem Prozessor definiert werden, welche Metriken bei den eingehenden Daten gezählt werden sollen. Bei dieser Option kann bei allen Metriken ein Haken gesetzt werden, womit die Konfiguration des Prozessors abgeschlossen ist.

Beim Funnel sind keine Konfigurationen notwendig, wodurch die benötigten Einstellungen der erstellten Elemente abgeschlossen sind. Im nächsten Schritt müssen die Elemente noch verknüpft werden, um die Kommunikation der Daten zu ermöglichen.

Die Kommunikation zwischen den Prozessoren erfolgt mittels sogenannter Relations (Verknüpfungen). Diese sind gerichtete Verbindungen welche den Fluss von Ein- und Ausgabedaten vorgeben.

Der Output eines Prozessors wird entlang einer ausgehenden Relation weitergeleitet, wobei die generierten Outputs in verschiedene Typen eingeteilt werden können. Für die meisten Prozessoren stehen die success- und failure-Relationen zur Verfügung, die ebenfalls in diesem Tutorial genutzt werden.
Falls Verarbeitung erfolgreich war, wird die Ausgabe entlang der success-Relation weitergeleitet. Falls es bei der Verarbeitung zu einem Fehler kommen sollte, werden die Daten entlang der failure-Relation übermittelt.
Alle Arten des Outputs müssen entweder durch mindestens eine Relation weitergeleitet werden oder explizit terminiert werden.

In der angelegten Konstellation fehlen aktuell die folgenden drei Relationen für eine korrekte Konfiguration:

Damit die generierten Daten des GenerateFlowFile-Prozessors zum CountText-Prozessor gelangen, muss daher zunächst eine Verbindung zwischen den beiden Prozessoren erstellt werden.

Diese Verknüpfung wird angelegt, indem per Drag-and-Drop aus der Mitte des Prozessors eine Verbindung zum nächsten gezogen wird.

Dadurch wird nun ein Auswahlmenü für die Art der gewünschten Relation angezeigt. Da der GenerateFlowFile-Prozessor keine Fehler erzeugen kann, steht nur eine success-Relation zur Verfügung.

Zusätzlich müssen die success/failure-Ausgaben des CountText-Prozessors konfiguriert werden. Die success-Relation kann ähnlich wie beim GenerateFlowFile-Prozessor an den Funnel gezogen werden. Da an dieser Stelle keine Fehler in der Verarbeitung erwartet werden , kann diese Relation explizit im Settings-Tab terminiert werden.

Dadurch sind alle nötigen Outputs und Inputs der Prozessoren mit Relationen konfiguriert und die Prozessoren können ausgeführt werden.

Durch einen Rechtsklick auf die Prozessoren können beide auf den Zustand "Running" umgestellt werden. Der GenerateFlowFile-Prozessor wird dadurch alle 30 Sekunden vom Scheduler ausgeführt, wodurch ein Flowfile generiert und an den CountText-Prozessor über die Relation übertragen und dort anschließend verarbeitet wird. Die Ergebnisse der gezählten Metriken werden vom CountText-Prozessor im Anschluss als Metadaten (Attribute) der FlowFiles erstellt. Der aktuelle Stand des Inhalts und der Attribute der Daten die verarbeitet wurden, werden nach der abschließenden Bearbeitung auf der Kante zwischen dem CountText-Prozessor und dem Funnel angezeigt. Durch das Klicken auf die Kante, können Daten in der Warteschlange im Konfigurationsbereich angesehen werden.

Die dargestellten Daten in der Warteschlange können zusätzlich ausgeklappt werden, um weitere Informationen zu den FlowFiles zu erhalten.

An dieser Stelle können unter Attribute die Metadaten und damit die Ergebnisse des CountText-Prozessors eingesehen werden. Des Weiteren befindet sich auf der rechten Seite der Content des FlowFiles, der in diesem Fall der eingetragene String ist.