FetchDistributedMapCache 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-standard-nar
Description¶
Calcule la (les) clé(s) de cache à partir des attributs du FlowFile, pour chaque FlowFile entrant, et récupère(nt) la (les) valeur(s) du mappage distribué associée(s) à chaque clé. S’il est configuré sans attribut de destination, le contenu du FlowFile entrant est remplacé par les données binaires reçues par le Distributed Map Cache. Si aucune valeur n’est stockée sous cette clé, le fichier de flux est routé vers « introuvable ». Notez que le processeur tentera toujours de lire l’intégralité de la valeur mise en cache dans la mémoire avant de la placer dans sa destination. Cela peut s’avérer problématique si la valeur mise en cache est très importante.
Exigences en matière d’entrées¶
REQUIRED
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Identificateur d’entrée dans le cache |
Une liste d’attributs de FlowFile délimitée par des virgules, ou les résultats d’instructions du langage d’expression d’attributs, qui seront évalués par rapport au FlowFile afin de déterminer la ou les valeurs utilisées pour identifier les doublons ; ce sont ces valeurs qui sont mises en cache. NOTE : Un seul identificateur d’entrée de cache est autorisé, sauf si Put Cache Value In Attribute est spécifié. Les consultations multiples de cache ne sont prises en charge que lorsque la destination est un ensemble d’attributs (voir la documentation relative à l’option « Put Cache Value In Attribute » pour plus de détails, notamment sur la convention d’appellation). |
Jeu de caractères |
L’ensemble de caractères dans lequel la valeur mise en cache est codée. Elle ne sera utilisée que lors du routage vers un attribut. |
Service de cache distribué |
Le Controller Service qui est utilisé pour obtenir les valeurs mises en cache. |
Longueur maximale à mettre dans l’attribut |
Si vous routez la valeur du cache vers un attribut du FlowFile (en paramétrant la propriété « Put Cache Value in attribute »), le nombre de caractères mis dans la valeur de l’attribut sera au maximum de cette quantité. Ceci est important car les attributs sont conservés en mémoire et les attributs de grande taille entraîneront rapidement des problèmes de saturation de la mémoire. Si la sortie est plus longue que cette valeur, elle sera tronquée. Envisagez de le réduire si possible. |
Placez la valeur du cache dans l’attribut |
Si ce paramètre est activé, la valeur du cache reçue sera placée dans un attribut de FlowFile au lieu d’un contenu de theFlowFile. La clé d’attribut à mettre est déterminée par l’évaluation de la valeur de cette propriété. Si plusieurs identificateurs d’entrée de cache sont sélectionnés, plusieurs attributs seront écrits, en utilisant la valeur évaluée de cette propriété, précédée d’un point (.) et du nom de l’identificateur d’entrée de cache. |
Relations¶
Nom |
Description |
|---|---|
failure |
S’il n’est pas possible de communiquer avec le cache ou si l’entrée du cache est évaluée comme étant vide, le FlowFile sera pénalisé et routé vers cette relation |
not-found |
Si l’identificateur d’entrée de cache d’un FlowFilen’a pas été trouvé dans le cache, il sera routé vers cette relation |
success |
Si le cache a été communiqué avec succès, il sera routé vers cette relation |
Écrit les attributs¶
Nom |
Description |
|---|---|
user-defined |
Si la propriété « Put Cache Value In Attribute » est définie, la valeur définie devient la clé de l’attribut et la valeur correspond à la réponse obtenue depuis le cache distribué (Distributed Map Cache). Si plusieurs identificateurs d’entrée de cache sont sélectionnés, plusieurs attributs seront écrits, en utilisant la valeur évaluée de cette propriété, précédée d’un point (.) et du nom de l’identificateur d’entrée de cache. Par exemple, si la propriété Identificateur d’entrée de cache est définie sur « id.name » et que la propriété définie par l’utilisateur s’appelle « fetched », deux attributs seront écrits, fetched.id et fetched.name, contenant leurs valeurs respectives. |