Notify 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-standard-nar
Description¶
Met en cache un identificateur de signal de version dans le cache distribué, éventuellement avec les attributs du FlowFile. Tout FlowFile en attente dans un processeur Wait correspondant sera libéré dès que ce signal dans le cache sera détecté.
Exigences en matière d’entrées¶
REQUIRED
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
attribute-cache-regex |
Tout attribut dont le nom correspond à cette expression régulière sera stocké dans le cache distribué afin d’être copié dans tout FlowFiles libéré depuis un processeur Wait correspondant. Notez que l’attribut uuid ne sera jamais mis en cache, quelle que soit cette valeur. S’il est vide, aucun attribut ne sera mis en cache. |
distributed-cache-service |
Le Controller Service utilisé pour mettre en cache les signaux de libération afin de libérer les fichiers mis en file d’attente dans un processeur Wait correspondant. |
release-signal-id |
Une valeur, ou le résultat d’une expression en Expression Language, qui sera évaluée par rapport à un FlowFile afin de déterminer la clé de cache du signal de libération. |
signal-buffer-count |
Spécifie le nombre maximal de fichiers en entrée pouvant être mis en mémoire tampon avant que les signaux ne soient notifiés au service de cache. Plus le tampon est important, meilleures sont les performances, car cela réduit le nombre d’interactions avec le service de cache en regroupant les signaux par identifiant lorsque plusieurs fichiers en entrée partagent le même identifiant. |
signal-counter-delta |
Une valeur, ou le résultat d’une expression en Expression Language, qui sera évaluée par rapport à un FlowFile afin de déterminer l’incrément du compteur de signal. Spécifie de combien le compteur doit augmenter. Par exemple, si plusieurs événements de signal sont traités en amont de manière groupée, le nombre d’événements traités peut être notifié avec cette propriété en une seule fois. La valeur zéro (0) a une signification particulière : elle remet le compteur cible à 0, ce qui est particulièrement utile avec le mode Wait Releasable FlowFile Count = Zero (0) pour fournir un contrôle de flux de type “open-close-gate”. La valeur un (1) peut ouvrir un processeur Wait correspondant, et la valeur zéro (0) peut le fermer comme si l’on fermait une porte. |
signal-counter-name |
Une valeur, ou le résultat d’une expression en Expression Language, qui sera évaluée par rapport à un FlowFile afin de déterminer le nom du compteur de signal. Le nom du compteur de signal est utile lorsqu’un processeur Wait correspondant doit connaître le nombre d’occurrences de différents types d’événements, tels que succès ou échec, ou les noms des sources de données de destination, etc. |
Relations¶
Nom |
Description |
|---|---|
failure |
Lorsque le cache est inaccessible, ou si le Release Signal Identifier est évalué à null ou vide, les FlowFiles sont routés vers cette relation. |
success |
Tous les FlowFiles pour lesquels le signal de libération a été correctement inscrit dans le cache sont routés vers cette relation. |
Écrit les attributs¶
Nom |
Description |
|---|---|
notified |
Tous les FlowFiles auront un attribut “notified”. La valeur de cet attribut est true si le FlowFile est notifié, sinon false. |