Apache NiFi - Flows erstellen
Apache NiFi bietet eine große Anzahl von Komponenten, mit denen Entwickler Datenflüsse für jede Art von Protokollen oder Datenquellen erstellen können. Um einen Flow zu erstellen, zieht ein Entwickler die Komponenten von der Menüleiste auf die Leinwand und verbindet sie durch Klicken und Ziehen der Maus von einer Komponente zur anderen.
Im Allgemeinen hat ein NiFi zu Beginn des Flusses eine Listener-Komponente wie getfile, die die Daten vom Quellsystem abruft. Am anderen Ende befindet sich eine Senderkomponente wie putfile und dazwischen befinden sich Komponenten, die die Daten verarbeiten.
Erstellen Sie beispielsweise einen Flow, der eine leere Datei aus einem Verzeichnis entnimmt, Text in diese Datei einfügt und in ein anderes Verzeichnis legt.
Ziehen Sie zunächst das Prozessorsymbol auf die NiFi-Zeichenfläche und wählen Sie GetFile-Prozessor aus der Liste aus.
Erstellen Sie ein Eingabeverzeichnis wie c:\inputdir.
Klicken Sie mit der rechten Maustaste auf den Prozessor und wählen Sie Konfigurieren und auf der Registerkarte Eigenschaften hinzufügen Input Directory (c:\inputdir) Klicken Sie auf Übernehmen und kehren Sie zur Leinwand zurück.
Ziehen Sie das Prozessorsymbol auf die Leinwand und wählen Sie den ReplaceText-Prozessor aus der Liste aus.
Klicken Sie mit der rechten Maustaste auf den Prozessor und wählen Sie Konfigurieren. In demproperties Registerkarte, fügen Sie etwas Text wie hinzu “Hello tutorialspoint.com” Klicken Sie im Textfeld Ersatzwert auf Übernehmen.
Gehen Sie zur Registerkarte "Einstellungen", aktivieren Sie das Kontrollkästchen "Fehler" auf der rechten Seite und kehren Sie dann zur Zeichenfläche zurück.
Verbinden Sie den GetFIle-Prozessor bei erfolgreicher Beziehung mit ReplaceText.
Ziehen Sie das Prozessorsymbol auf die Leinwand und wählen Sie den PutFile-Prozessor aus der Liste aus.
Erstellen Sie ein Ausgabeverzeichnis wie c:\outputdir.
Klicken Sie mit der rechten Maustaste auf den Prozessor und wählen Sie Konfigurieren. Fügen Sie auf der Registerkarte Eigenschaften hinzuDirectory (c:\outputdir) Klicken Sie auf Übernehmen und kehren Sie zur Leinwand zurück.
Gehen Sie zur Registerkarte "Einstellungen" und aktivieren Sie das Kontrollkästchen "Fehler und Erfolg" auf der rechten Seite. Kehren Sie dann zur Zeichenfläche zurück.
Verbinden Sie den ReplaceText-Prozessor mit PutFile bei erfolgreicher Beziehung.
Starten Sie nun den Flow und fügen Sie eine leere Datei in das Eingabeverzeichnis ein. Sie werden sehen, dass diese in das Ausgabeverzeichnis verschoben wird und der Text zur Datei hinzugefügt wird.
Durch Befolgen der obigen Schritte können Entwickler einen beliebigen Prozessor und eine andere NiFi-Komponente auswählen, um einen geeigneten Ablauf für ihre Organisation oder ihren Kunden zu erstellen.