GetAzureQueueStorage_v12 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-azure-nar
Description¶
Récupère les messages à partir d’un stockage Azure Queue Storage. Les messages récupérés seront supprimés de la file d’attente par défaut. Si l’exigence est de consommer les messages sans les supprimer, réglez l’option de suppression automatique des messages sur « false ». Remarque : Il est possible que vous receviez des doublons, par exemple lorsqu’un message a été reçu mais n’a pas pu être supprimé de la file d’attente en raison d’une situation inattendue.
Exigences en matière d’entrées¶
FORBIDDEN
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Suppression automatique des messages |
Indique si le message reçu doit être automatiquement supprimé de la file d’attente. |
Service des identifiants de connexion |
Controller Service utilisé pour obtenir les identifiants de connexion au stockage Azure. |
Taille des lots de messages |
Le nombre de messages à récupérer dans la file d’attente. |
Nom de la file d’attente |
Nom de la file d’attente de stockage Azure |
Délai d’expiration de la requête |
Le délai d’expiration des requêtes de lecture ou d’écriture vers le stockage en file d’attente Azure. La valeur par défaut est de 1 seconde. |
Délai d’expiration de la visibilité |
Durée pendant laquelle le message récupéré doit être invisible pour les autres consommateurs. |
service proxy-configuration |
Spécifie le Controller Service de configuration proxy pour les requêtes réseau proxy. Dans le cas de SOCKS, il n’est pas garanti que la version SOCKS sélectionnée sera utilisée par le processeur. |
storage-endpoint-suffix |
Les comptes de stockage dans Azure public utilisent toujours un suffixe commun FQDN. Remplacez ce suffixe de point de terminaison par un suffixe différent dans certaines circonstances (comme Azure Stack ou les régions Azure non publiques). |
Relations¶
Nom |
Description |
|---|---|
success |
Tous les FlowFiles dont le traitement a abouti sont routés vers cette relation |
Écrit les attributs¶
Nom |
Description |
|---|---|
azure.queue.uri |
L’adresse URI absolue du stockage de file d’attente Azure configuré |
azure.queue.insertionTime |
Heure à laquelle le message a été inséré dans le stockage de la file d’attente |
azure.queue.expirationTime |
L’heure à laquelle le message expirera du stockage de la file d’attente |
azure.queue.messageId |
ID du message récupéré |
azure.queue.popReceipt |
La réception pop du message récupéré |