Notify 2025.10.2.19¶
Bundle¶
org.apache.nifi | nifi-standard-nar
Description¶
Met en cache un identificateur de signal de déclenchement dans le cache distribué, éventuellement avec les attributs du FlowFile. Tous les fichiers de flux conservés dans un processeur Wait correspondant seront libérés une fois que ce signal dans le cache aura été découvert.
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 |
Tous les attributs dont les noms correspondent à cette expression régulière seront stockés dans le cache distribué pour être copiés dans tous les FlowFiles libérés par un processeur Wait correspondant. Notez que l’attribut uuid ne sera pas mis en cache, quelle que soit cette valeur. Si 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. |