JoltTransformRecord 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-jolt-nar
Description¶
Applique une spécification JOLT à chaque enregistrement de la charge utile FlowFile. Un nouveau FlowFile est créé avec le contenu transformé et est routé vers la relation « success ». Si la transformation échoue, le FlowFile original est routé vers la relation « failure ».
Exigences en matière d’entrées¶
REQUIRED
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Répertoire des modules personnalisés |
Liste de chemins vers des fichiers et/ou des répertoires contenant des modules de transformations personnalisées (qui ne sont pas inclus dans le chemin de classe de NiFi), séparés par des virgules. |
Nom de la classe de transformation personnalisée |
Nom de classe entièrement qualifié pour la transformation personnalisée |
Jolt Specification |
La spécification Jolt pour la transformation des données JSON. La valeur de cette propriété peut être le texte d’une spécification Jolt ou le chemin vers un fichier contenant une spécification Jolt. La valeur ‘Jolt Specification’ doit être définie, sinon la valeur est ignorée si la transformation du tri Jolt est sélectionnée. |
Jolt Transform |
Spécifie la transformation Jolt à utiliser avec la spécification fournie. |
Taille du cache de transformation |
L’élaboration d’une transformation Jolt peut être assez coûteuse. Dans l’idéal, cette opération ne sera effectuée qu’une seule fois. Toutefois, si la langue d’expression est utilisée dans la transformation, il se peut que nous ayons besoin d’une nouvelle transformation pour chaque FlowFile. Cette valeur détermine le nombre de ces transformations que nous mettons en cache dans la mémoire afin d’éviter d’avoir à compiler la transformation à chaque fois. |
jolt-record-record-reader |
Spécifie le Controller Service à utiliser pour analyser les données entrantes et déterminer le schéma des données. |
jolt-record-record-writer |
Spécifie le Controller Service à utiliser pour la génération des enregistrements en sortie |
Relations¶
Nom |
Description |
|---|---|
failure |
Si le traitement d’un FlowFile échoue pour une raison quelconque (par exemple, les enregistrements FlowFile ne peuvent pas être analysés), il sera routé vers cette relation |
original |
Le FlowFile d’origine a été transformé. Si le traitement du FlowFile échoue, rien ne sera envoyé à cette relation |
success |
Le FlowFile dont le contenu a été transformé sera routé vers cette relation |
Écrit les attributs¶
Nom |
Description |
|---|---|
record.count |
Le nombre d’enregistrements dans un FlowFile sortant |
mime.type |
Le type MIME que le Record Writer configuré indique comme étant approprié |