FetchDistributedMapCache 2025.10.2.19¶
Bundle¶
org.apache.nifi | nifi-standard-nar
Description¶
Computes cache key(s) from FlowFile attributes, for each incoming FlowFile, and fetches the value(s) from the Distributed Map Cache associated with each key. If configured without a destination attribute, the incoming FlowFile “s content is replaced with the binary data received by the Distributed Map Cache. If there is no value stored under that key then the flow file will be routed to” not-found “. Note that the processor will always attempt to read the entire cached value into memory before placing it in it’s destination. This could be potentially problematic if the cached value is very large.
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. |