ScriptedPartitionRecord 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-scripting-nar
Description¶
Reçoit des données orientées enregistrements (c’est-à-dire des données pouvant être lues par le Record Reader configuré) et exécute le script fourni par l’utilisateur sur chaque enregistrement du FlowFile entrant. Chaque enregistrement est ensuite regroupé avec d’autres enregistrements partageant la même partition, et un FlowFile est créé pour chaque groupe d’enregistrements. Deux enregistrements partagent la même partition si l’évaluation du script renvoie la même valeur pour les deux. Ils seront considérés comme faisant partie de la même partition.
Exigences en matière d’entrées¶
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
---|---|
Répertoire des modules |
Liste séparée par des virgules des chemins d’accès aux fichiers et/ou répertoires contenant les modules requis par le script. |
Record Reader |
Le Record Reader à utiliser pour analyser le contenu de FlowFile en enregistrements |
Record Writer |
Le Record Writer à utiliser pour sérialiser les enregistrements après qu’ils aient été transformés |
Corps du script |
Corps du script à exécuter. Un seul fichier de script ou corps de script peut être utilisé |
Moteur de script |
La langue à utiliser pour le script |
Fichier script |
Chemin d’accès au fichier script à exécuter. Un seul fichier de script ou corps de script peut être utilisé |
Restrictions¶
Autorisation requise |
Explication |
---|---|
exécuter le code |
Fournit à l’opérateur la possibilité d’exécuter un code arbitraire en bénéficiant de toutes les autorisations dont dispose NiFi. |
Relations¶
Nom |
Description |
---|---|
failure |
Si un FlowFile ne peut pas être partitionné du format d’entrée configuré vers le format de sortie configuré, le FlowFile inchangé sera acheminé vers cette relation. |
original |
Une fois que tous les enregistrements d’un FlowFile entrant ont été partitionnés, le FlowFile original est acheminé vers cette relation. |
success |
Les FlowFiles partitionnés avec succès seront acheminés vers cette relation. |
Écrit les attributs¶
Nom |
Description |
---|---|
partition |
La partition du FlowFile sortant. Si le script indique que la partition a une valeur null, l’attribut sera défini sur la chaîne littérale « <null partition> » (sans guillemets). Sinon, l’attribut est défini sur la représentation sous forme de chaîne de la valeur renvoyée par le script. |
mime.type |
Définit l’attribut mime.type sur le type MIME spécifié par le Record Writer |
record.count |
Nombre d’enregistrements dans le FlowFile. |
record.error.message |
Cet attribut fournit, en cas d’échec, le message d’erreur rencontré par le Record Reader ou le Record Writer. |
fragment.index |
Un numéro séquentiel indiquant l’ordre des FlowFiles partitionnés créés à partir d’un même FlowFile parent. |
fragment.count |
Le nombre de FlowFiles partitionnés générés à partir du FlowFile parent. |