AzureQueueStorageConnector
Accède au service Azure Queue Storage pour envoyer et recevoir des messages.
Utilisations typiques
- Agréger des données de files d'attente et autres flux de messages.
- Déclencher une action depuis un message.
Comment fonctionne-t-il ?
AzureQueueStorageConnector utilise votre compte Azure Storage (soit via une ancienne connexion web FME, soit en définissant une nouvelle connexion via le Transformer) pour accéder au service de stockage de fichiers.
Notes
- Le service de file d'attente de stockage du service encode et décode les messages en utf-8 par défaut.
Configuration
Ports d'entrée
Ce Transformer accepte tous types d'entités.
Ports de sortie
La sortie de ce Transformer varie en fonction de l'action effectuée. Les données de message et les métadonnées sont présentées comme des attributs d'entité.
- Après une action Réception, les entités en sortie représentent les messages reçus depuis la file d'attente.
- Après une action Envoi, les entités en sortie représentent les messages envoyés à la file d'attente.
L'entité entrante ressort par ce port.
Les entités qui provoquent l'échec de l'opération ressortent par ce port. Un attribut fme_rejection_code, ayant la valeur ERROR_DURING_PROCESSING, sera ajouté, ainsi qu'un attribut fme_rejection_message plus descriptif qui contient des détails plus spécifiques sur la raison de l'échec.
Note: Si une entité arrive dans AzureQueueStorageConnector en ayant déjà une valeur pour fme_rejection_code, cette valeur sera supprimée.
Gestion des entités rejetées : ce paramètre permet d'interrompre la traduction ou de la poursuivre lorsqu'elle rencontre une entité rejetée. Ce paramètre est disponible à la fois comme option par défaut de FME et comme paramètre de traitement.
Paramètres
Source des identifiants |
Requis pour l'authentification. L'utilisation d'une connexion Web s'intègre le mieux à FME, mais dans certains cas, vous pouvez souhaiter utiliser l'une des autres sources.
|
Compte |
Disponible lorsque la source d'accréditation est Connexion web. Pour créer une connexion Azure Storage, cliquez sur le menu déroulant "Compte" et sélectionnez "Ajouter une connexion web…". La connexion pourra ensuite être gérée via Outils -> Options FME... -> Connexions Web. |
Nom de compte | Disponible lorsque la source d'accréditation est SAS ou Intégré. Un nom de compte et une clé de compte ou une signature d'accès partagé peuvent être spécifiés directement dans le Transformer. |
Clé de compte | Disponible lorsque la source d'accréditation est Intégrée. Un nom de compte et une clé d'accès peuvent être spécifiés directement dans le Transformer au lieu d'une connexion web. |
Signature d'Accès Partagé (SAP, ou SAS pour Shared Account Signature) | Disponible lorsque la source d'accréditation est SAS. Un nom de compte et une signature d'accès partagé peuvent être spécifiés directement dans le Transformer. |
Action |
Le type d'opération à effectuer. Les choix possibles sont :
|
Les autres paramètres disponibles dépendent de la valeur du paramètre Action > Action. Les paramètres de chaque action sont détaillés ci-dessous.
Supprime les messages de la file d'attente.
Options de suppression des messages
File d'attente |
La file d'attente dans laquelle les messages doivent être supprimés. Une file d'attente peut être saisie manuellement, ou sélectionnée de manière interactive en cliquant sur les ellipses. |
Supprimer tous les messages |
Si Oui, tous les messages de la file d'attente seront supprimés. Si Non, le message avec l'ID spécifié et le reçu POP sera supprimé. |
ID de message |
Requis pour la suppression d'un message. Récupéré lors d'une opération de réception précédente. |
Reçu POP |
Requis pour la suppression d'un message. Récupéré lors d'une opération de réception précédente. |
Délai d'attente du serveur (secondes) |
Le temps maximum à attendre pour que le serveur complète l'opération demandée. |
Reçoit les messages depuis le début de la file d'attente sans altérer la visibilité des messages.
Options d'aperçu des messages
File d'attente |
La file d'attente pour consulter les messages. Une file d'attente peut être saisie manuellement, ou sélectionnée de manière interactive en cliquant sur les ellipses. |
Nombre de messages |
Le nombre de messages sur lesquels faire un aperçu dans la queue. |
Délai d'attente du serveur (secondes) |
Le temps maximum à attendre pour que le serveur complète l'opération demandée. |
Réception de messages depuis le début de la file d'attente.
Options de réception des messages
File d'attente |
La file d'attente pour recevoir les messages. Une file d'attente peut être saisie manuellement, ou sélectionnée de manière interactive en cliquant sur les ellipses. |
Mode |
Deux options de réception de messages sont disponibles :
|
Nombre de messages |
Spécifie le nombre de messages à lire pour l'opération. Pour le mode Flux, il s'agit du nombre de messages récupérés par intervalle d'interrogation. Pour le mode Par lots, il s'agit du nombre total de messages récupérés. |
Intervalle de réponse (secondes) |
Quand le mode est Flux, la période à attendre entre la réception de message. |
Supprimer à la réception |
Si oui, les messages sont supprimés dès qu'ils sont reçus de la file d'attente. Si non, les messages peuvent être reçus à nouveau après le délai de visibilité. |
Délai de visibilité (secondes) |
Le temps pendant lequel le message est invisible. Après l'expiration du délai, le message est visible. La valeur par défaut est de 30 secondes. |
Délai d'attente du serveur (secondes) |
Le temps maximum à attendre pour que le serveur complète l'opération demandée. |
Options d'envoi des messages
File d'attente |
La file d'attente à partir de laquelle envoyer les messages. Une file d'attente peut être saisie manuellement, ou sélectionnée de manière interactive en cliquant sur les ellipses. |
Contenu |
Un message codé. L'encodage par défaut est une chaîne unicode xml. |
Mise à jour de messages |
Si Oui, mettre à jour un message dans le service de file d'attente. Cette opération peut être utile pour "louer" un message si le traitement de l'espace de travail n'est pas terminé. L'invisibilité d'un message peut être prolongée en mettant à jour le délai de visibilité. |
ID de message |
Requis pour la mise à jour d'un message. Récupéré lors d'une opération de réception précédente. |
Reçu POP |
Requis pour la mise à jour d'un message. Récupéré lors d'une opération de réception précédente. |
Délai d'expiration |
Si Oui, définissez la durée de vie du message. Si Non, le message n'expire jamais. |
Délai d'expiration (secondes) |
Durée de vie du message. La valeur par défaut et maximale est de 7 jours. Après la durée spécifiée, le message est définitivement supprimé de la file d'attente. |
Délai de visibilité (secondes) |
Le temps pendant lequel le message est invisible. Après l'expiration du délai, le message est visible. La valeur par défaut est de 30 secondes. |
Délai d'attente du serveur (secondes) |
Le temps maximum à attendre pour que le serveur complète l'opération demandée. |
Les attributs suivants peuvent être sélectionnés pour être inclus dans les entités de sortie. Chaque entité de sortie représente un message qui a été soit envoyé, soit reçu.
_id |
L'identifiant d'un message. Requis pour la mise à jour et la suppression. |
_value |
Le contenu du message. |
_dequeue_count |
Nombre de fois qu'un message a été récupéré, soit depuis une action d'aperçu soit depuis une action de réception. |
_expiration_time |
Le délai d'expiration du message en temps unix. |
_pop_receipt |
Le reçu POP d'un message, obtenu depuis une opération de réception. Nécessaire pour la mise à jour et la suppression. |
_time_next_visible |
La durée après laquelle le message est visible en temps unix. |
_timestamp |
La date de création du message en temps unix. |
Éditer les paramètres des Transformers
À l'aide d'un ensemble d'options de menu, les paramètres du Transformer peuvent être attribués en faisant référence à d'autres éléments du traitement. Des fonctions plus avancées, telles qu'un éditeur avancé et un éditeur arithmétique, sont également disponibles dans certains Transformers. Pour accéder à un menu de ces options, cliquez sur à côté du paramètre applicable. Pour plus d'informations, voir Options de menus et paramètres de Transformer.
Définir les valeurs
Il existe plusieurs façons de définir une valeur à utiliser dans un Transformer. La plus simple est de simplement taper une valeur ou une chaîne de caractères, qui peut inclure des fonctions de différents types comme des références d'attributs, des fonctions mathématiques et de chaînes de caractères, et des paramètres d'espace de travail. Il existe un certain nombre d'outils et de raccourcis qui peuvent aider à construire des valeurs, généralement disponibles dans le menu contextuel déroulant adjacent au champ de valeur.
Utilisation de l'éditeur de texte
L'éditeur de texte fournit un moyen efficace de construire des chaînes de textes (dont les expressions régulières) à partir de données source diverses, telles que des attributs, des paramètres et des constantes, et le résultat est directement utilisé dans le paramètre.
Utilisation de l'éditeur arithmétique
L'éditeur arithmétique fournit un moyen simple de construire des expressions mathématiques à partir de plusieurs données source, telles que des attributs et des fonctions, et le résultat est directement utilisé dans un paramètre.
Valeur conditionnelle
Définit des valeurs selon un ou plusieurs tests.
Fenêtre de définition de conditions
Contenu
Les expressions et chaînes de caractères peuvent inclure des fonctions, caractères, paramètres et plus.
Lors du paramétrage des valeurs - qu'elles soient entrées directement dans un paramètre ou construites en utilisant l'un des éditeurs - les chaînes de caractères et les expressions contenant des fonctions Chaîne de caractères, Math, Date et heure ou Entité FME auront ces fonctions évaluées. Par conséquent, les noms de ces fonctions (sous la forme @<nom_de_fonction>) ne doivent pas être utilisés comme valeurs littérales de chaîne de caractères.
Ces fonctions manipulent les chaînes de caractères. | |
Caractères spéciaux |
Un ensemble de caractères de contrôle est disponible dans l'éditeur de texte. |
Plusieurs fonctions sont disponibles dans les deux éditeurs. | |
Fonctions Date/heure | Les fonctions de dates et heures sont disponibles dans l'Editeur texte. |
Ces opérateur sont disponibles dans l'éditeur arithmétique. | |
Elles retournent des valeurs spécifiques aux entités. | |
Les paramètres FME et spécifiques au projet peuvent être utilisés. | |
Créer et modifier un paramètre publié | Créer ses propres paramètres éditables. |
Options - Tables
Les Transformers avec des paramètres de style table possèdent des outils additionnels pour remplir et manipuler des valeurs.
Réordonner
|
Activé une fois que vous avez cliqué sur un élément de ligne. Les choix comprennent :
|
Couper, Copier et Coller
|
Activé une fois que vous avez cliqué sur un élément de ligne. Les choix comprennent :
Copier, copier et coller peuvent être utilisés au sein d'un Transformer ou entre Transfromers. |
Filtre
|
Commencez à taper une chaîne de caractères, et la matrice n'affichera que les lignes correspondant à ces caractères. Recherche dans toutes les colonnes. Cela n'affecte que l'affichage des attributs dans le Transformer - cela ne change pas les attributs qui sont sortis. |
Importer
|
Le bouton d'import remplit la table avec un jeu de nouveaux attributs lus depuis un jeu de données. L'application spécifique varie selon les Transformers. |
Réinitialiser/Rafraîchir
|
Réinitialise la table à son état initial, et peut fournir des options additionnelles pour supprimer des entrées invalides. Le comportement varie d'un Transformer à l'autre. |
Note : Tous les outils ne sont pas disponibles dans tous les Transformers.
Références
Comportement |
|
Stockage des entités |
Non |
Dépendances | Compte Azure Storage |
Alias | MicrosoftAzureQueueStorageConnector |
Historique | Implémenté dans FME 2019.0 |
FME Community
FME Community iest l'endroit où trouver des démos, des tutoriaux, des articles, des FAQ et bien plus encore. Obtenez des réponses à vos questions, apprenez des autres utilisateurs et suggérez, votez et commentez de nouvelles entités.
Rechercher tous les résultats sur ce Transformer sur FME Community.
Les exemples peuvent contenir des informations sous licence Open Government - Vancouver et/ou Open Government - Canada.