LookupRecord 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-standard-nar
Description¶
Extrait un ou plusieurs champs d’un enregistrement et recherche une valeur pour ces champs dans LookupService. Si LookupService renvoie un résultat, celui-ci est éventuellement ajouté à l’enregistrement. Dans ce cas, le processeur fonctionne comme un processeur d’enrichissement. Quoi qu’il en soit, l’enregistrement est ensuite routé vers la relation « correspondante » ou « non correspondante » (si la propriété de stratégie de routage est configurée à cet effet), en indiquant si un résultat a été renvoyé par le LookupService, ce qui permet au processeur de fonctionner également comme un processeur de routage. Les « coordonnées » à utiliser pour rechercher une valeur dans le service de consultation sont définies par l’ajout d’une propriété définie par l’utilisateur. Pour chaque propriété ajoutée, une entrée est ajoutée à une carte, où le nom de la propriété devient la clé de la carte et la valeur renvoyée par le site RecordPath devient la valeur de cette clé. Si plusieurs valeurs sont renvoyées par RecordPath, l’enregistrement sera routé vers la relation « unmatched » (ou « success », en fonction de la configuration de la propriété de stratégie de routage). Si un ou plusieurs champs correspondent au résultat RecordPath, tous les champs correspondants seront mis à jour. S’il n’y a pas de correspondance dans la configuration LookupService, aucun champ ne sera mis à jour. C’est-à-dire qu’il ne remplacera pas une valeur existante dans l’enregistrement par une valeur nulle. Notez toutefois que si les résultats renvoyés par LookupService ne sont pas pris en compte dans votre schéma (en particulier, le schéma configuré pour votre Record Writer), les champs ne seront pas écrits dans FlowFile.
Exigences en matière d’entrées¶
REQUIRED
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Chemin de l’enregistrement racine |
Un RecordPath qui pointe vers un enregistrement enfant dans chacun des enregistrements de premier niveau de FlowFile. S’il est précisé, les propriétés supplémentaires de RecordPath seront évaluées par rapport à cet enregistrement enfant et non par rapport à l’enregistrement de premier niveau. Cela permet d’effectuer un enrichissement sur plusieurs enregistrements enfants à l’intérieur d’un seul enregistrement de premier niveau. |
lookup-service |
Le service de consultation à utiliser pour rechercher une valeur dans chaque enregistrement |
record-path-lookup-miss-result-cache-size |
Indique combien de valeurs/d’enregistrements de consultation doivent être mis en cache. Le paramètre zéro signifie qu’aucune mise en cache n’est effectuée et que la table est interrogée pour chaque valeur de consultation dans chaque enregistrement. Si la table de recherche change souvent ou si les données les plus récentes doivent être récupérées, n’utilisez pas le cache. |
record-reader |
Spécifie le Controller Service à utiliser pour la lecture des données entrantes |
record-update-strategy |
Cette propriété définit la stratégie à utiliser pour mettre à jour l’enregistrement avec la valeur retournée par le service de consultation. |
record-writer |
Spécifie le Controller Service à utiliser pour la génération des enregistrements en sortie |
result-contents |
Lorsqu’un résultat contenant un enregistrement est obtenu, cette propriété détermine si l’enregistrement lui-même est inséré dans le chemin configuré ou si le contenu de l’enregistrement (c’est-à-dire les sous-champs) sera inséré au chemin configuré. |
result-record-path |
Un RecordPath qui pointe vers le champ dont la valeur doit être mise à jour en fonction de la valeur retournée par le service de consultation. S’il n’est pas spécifié, la valeur retournée par le service de consultation sera ignorée, sauf pour déterminer si le FlowFile doit être routé vers la relation « matched » ou « unmatched ». |
routing-strategy |
Indique comment router les enregistrements après la fin d’une consultation |
Relations¶
Nom |
Description |
|---|---|
failure |
Si un FlowFile ne peut pas être enrichi, le FlowFile inchangé sera routé vers cette relation |
success |
Tous les enregistrements seront envoyés à cette relation si elle est configurée à cet effet, à moins qu’une défaillance ne se produise |
Écrit les attributs¶
Nom |
Description |
|---|---|
mime.type |
Définit l’attribut mime.type sur le type MIME spécifié par le Record Writer |
record.count |
Le nombre d’enregistrements dans le FlowFile |