Relation Apache NiFi - Processeurs

Dans un flux de données Apache NiFi, les fichiers de flux passent d'un processeur à un autre via une connexion qui est validée à l'aide d'une relation entre processeurs. Chaque fois qu'une connexion est créée, un développeur sélectionne une ou plusieurs relations entre ces processeurs.

Comme vous pouvez le voir dans l'image ci-dessus, les cases à cocher dans le rectangle noir sont des relations. Si un développeur sélectionne ces cases à cocher, le fichier de flux se terminera dans ce processeur particulier, lorsque la relation réussit ou échoue, ou les deux.

Succès

Lorsqu'un processeur traite avec succès un fichier de flux comme stocker ou récupère des données à partir de n'importe quelle source de données sans obtenir de connexion, d'authentification ou toute autre erreur, le fichier de flux passe en relation de succès.

Échec

Lorsqu'un processeur n'est pas en mesure de traiter un fichier de flux sans erreurs telles qu'une erreur d'authentification ou un problème de connexion, etc., alors le fichier de flux passe à une relation d'échec.

Un développeur peut également transférer les fichiers de flux vers d'autres processeurs à l'aide de connexions. Le développeur peut le sélectionner et également l'équilibrer de charge, mais l'équilibrage de charge vient juste d'être publié dans la version 1.8, qui ne sera pas abordée dans ce tutoriel.

Comme vous pouvez le voir dans l'image ci-dessus, la connexion marquée en rouge a une relation d'échec, ce qui signifie que tous les fichiers de flux avec des erreurs iront au processeur à gauche et respectivement tous les fichiers de flux sans erreurs seront transférés à la connexion marquée en vert.

Passons maintenant aux autres relations.

comms.failure

Cette relation est respectée lorsqu'un Flowfile n'a pas pu être extrait du serveur distant en raison d'un échec de communication.

pas trouvé

Tout Flowfile pour lequel nous recevons un message «Not Found» du serveur distant sera déplacé vers not.found relation.

permission refusée

Lorsque NiFi ne peut pas récupérer un fichier de flux à partir du serveur distant en raison d'une autorisation insuffisante, il se déplacera à travers cette relation.