AzureServiceBusConnector
Se connecte au bus de service Azure à l'aide du SDK Azure Service Bus.
Cas d'utilisations typiques
-
Recevoir et envoyer des messages à partir d'une file d'attente ou d'un sujet
- Interopérabilité avec des plateformes d'analyse Big Data
Comment fonctionne-t-il ?
AzureServiceBusConnector se connecte au bus de service Azure à l'aide du SDK Azure Service Bus.
Service Bus utilise le protocole AMQP 1.0. Le connecteur prend en charge l'envoi et la réception de messages.
De plus amples informations sur le Service Bus sont disponibles dans la documentation officielle de Microsoft.
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 Recevoir depuis la file d'attente, les entités de sortie représentent les messages reçus d'une file d'attente Azure Service Bus.
-
Après une action Recevoir depuis un abonnement, les entités en sortie représentent les messages reçus depuis l'abonnement.
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é entrant dans AzureServiceBusConnector possède déjà une valeur pour fme_rejection_code, cette dernière 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 Service Bus, 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. |
Informations d'authentification intégrées
Chaîne de connexion du bus de service |
Disponible lorsque la source d'authentification est intégrée. La chaîne de connexion se trouve dans l'espace de noms Azure Portal Event Hubs sous Shared Access Policies. |
Action |
Le type d'opération à effectuer. Les choix possibles sont :
|
Hubs d'événements |
Le hub de l'événement auquel se connecter. |
Les autres paramètres disponibles dépendent de la valeur du paramètre Requête > Action. Les paramètres de chaque action sont détaillés ci-dessous.
Options - Recevoir depuis la file d'attente
Mode de réception |
Deux options de réception de messages sont disponibles :
|
Supprimer à la réception |
Si oui, le message est supprimé de la file d'attente dès sa réception. Si non, le message est récupéré mais reste dans la file d'attente. Le message pourra être reçu après la période de blocage. |
Taille des lots |
La méthode Par lots (Batch) spécifie le nombre de messages à lire par lot. La valeur par défaut est 1. |
Options - Recevoir depuis un abonnement
Mode de réception |
Deux options de réception de messages sont disponibles :
|
Supprimer à la réception |
Si oui, le message est supprimé de l'abonnement dès sa réception. Si non, le message est récupéré mais reste dans l'abonnement. Le message pourra être reçu après la période de blocage. |
Taille des lots |
La méthode Par lots (Batch) spécifie le nombre de messages à lire par lot. La valeur par défaut est 1. |
Options - Envoyer à la file d'attente
File d'attente |
La file d'attente à laquelle envoyer les messages. |
Créer une file d'attente |
Si oui, créer la file d'attente avec le nom donné. Un message sera enregistré si la file d'attente existe déjà. Si non, utilise la file d'attente disponible. |
Payload |
Contenu du message Il s'agit souvent de JSON, mais il peut s'agir de n'importe quelle chaîne, binaire, nombre entier ou valeur en virgule flottante. |
Propriétés du message |
Propriétés du message paramétrables. Toute valeur de clé peut être utilisée, mais les clés suivantes sont associées aux attributs respectifs du message.
|
Options - Envoi au sujet
Sujet |
Le sujet auquel envoyer les messages. |
Créer sujet |
Si oui, créer le sujet avec le nom donné. Un message sera enregistré si la file d'attente existe déjà. Si non, utilise le sujet disponible. |
Payload |
Contenu du message Il s'agit souvent de JSON, mais il peut s'agir de n'importe quelle chaîne, binaire, nombre entier ou valeur en virgule flottante. |
Propriétés du message |
Propriétés du message paramétrables. Toute valeur de clé peut être utilisée, mais les clés suivantes sont associées aux attributs respectifs du message.
|
Options Compte des message
Ressource |
La ressource pour compter les messages disponibles. Soit File d'attente, soit Abonnement. |
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.
_payload |
La charge utile du message. Chaîne UTF-8 si possible à décoder, sinon binaire ou numérique. |
_properties |
Une paire clé/valeur des propriétés du message. |
_content_type |
Le type de contenu paramétrable du message. |
_correlation_id |
L'identifiant de corrélation paramétrable du message. |
_enqueued_sequence_number |
La position du message dans la file d'attente/l'abonnement. |
_enqueued_time |
L'horodatage FME du moment où un message a été ajouté à la file d'attente ou à l'abonnement. |
_expires_at |
L'horodatage FME de l'expiration du message. |
_lock_tocken |
Un uuid utilisé pour indiquer que le message a été reçu mais qu'il n'a pas été complété ou supprimé. Il empêche les autres destinataires de recevoir le message |
_locked_until |
Horodatage FME indiquant que le message sera déverrouillé afin de pouvoir être reçu à nouveau. |
_message_id |
L'id paramétrable d'un message. |
_partition_key |
La clé de partition dans laquelle est le message. |
_reply_to |
La réponse paramétrable à un message. |
_sequence_number |
Le numéro de séquence d'un message. |
_subject |
Le sujet paramétrable d'un message. |
_time_to_live |
L'horodatage FME de la durée pendant laquelle le message restera dans la file d'attente/l'abonnement. |
_to |
Le destinataire paramétrable d'un message. |
É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 de 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 de traitement. 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 traitement 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 Microsoft Azure avec le bus de service Service Bus |
Alias | |
Historique | Implémenté dans FME 2019.2 |
FME Community
FME Community est 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.
Voir tous les résultats à propos de ce Transformer sur FME Community.
Les exemples peuvent contenir des informations sous licence Open Government - Vancouver et/ou Open Government - Canada.