Apache NiFi - Création de flux

Apache NiFi propose un grand nombre de composants pour aider les développeurs à créer des flux de données pour tout type de protocoles ou sources de données. Pour créer un flux, un développeur fait glisser les composants de la barre de menus vers le canevas et les connecte en cliquant et en faisant glisser la souris d'un composant à l'autre.

Généralement, un NiFi a un composant écouteur au début du flux comme getfile, qui récupère les données du système source. À l'autre extrémité, il y a un composant émetteur comme putfile et il y a des composants entre les deux, qui traitent les données.

Par exemple, créons un flux, qui prend un fichier vide dans un répertoire et ajoute du texte dans ce fichier et le place dans un autre répertoire.

• Pour commencer, faites glisser l'icône du processeur sur le canevas NiFi et sélectionnez le processeur GetFile dans la liste.

• Créez un répertoire d'entrée comme c:\inputdir.

• Cliquez avec le bouton droit sur le processeur et sélectionnez configurer et dans l'onglet Propriétés ajouter Input Directory (c:\inputdir) et cliquez sur Appliquer et revenez au canevas.

• Faites glisser l'icône du processeur sur le canevas et sélectionnez le processeur ReplaceText dans la liste.

• Cliquez avec le bouton droit sur le processeur et sélectionnez configurer. dans leproperties onglet, ajoutez du texte comme “Hello tutorialspoint.com” dans la zone de texte Valeur de remplacement et cliquez sur Appliquer.

• Accédez à l'onglet Paramètres, cochez la case d'échec sur le côté droit, puis revenez au canevas.

• Connectez le processeur GetFIle à ReplaceText sur la relation de réussite.

• Faites glisser l'icône du processeur sur le canevas et sélectionnez le processeur PutFile dans la liste.

• Créez un répertoire de sortie comme c:\outputdir.

• Cliquez avec le bouton droit sur le processeur et sélectionnez configurer. Dans l'onglet des propriétés, ajoutezDirectory (c:\outputdir) et cliquez sur Appliquer et revenez au canevas.

• Accédez à l'onglet Paramètres et cochez la case Échec et réussite sur le côté droit, puis revenez au canevas.

• Connectez le processeur ReplaceText à PutFile sur la relation de réussite.

• Maintenant, démarrez le flux et ajoutez un fichier vide dans le répertoire d'entrée et vous verrez que, il se déplacera vers le répertoire de sortie et le texte sera ajouté au fichier.

En suivant les étapes ci-dessus, les développeurs peuvent choisir n'importe quel processeur et autre composant NiFi pour créer un flux adapté à leur organisation ou client.