RabbitMQConnector

Input

Ce Transformer accepte tous types d'entités.

Output

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, les entités en sortie correspondent aux messages reçus depuis le courtier.
Après une action Envoyer, les entités en sortie correspondent aux messages envoyés au courtier.
Après une action Compte, le nombre de messages dans la queue est généré.
Après une action Accusé de réception, les messages sont marqués comme ayant fait l'objet d'un accusé de réception. Il n'y a pas d'entité en sortie.

Initiator

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 RabbitMQConnector 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.

Authentification

Source des identifiants

Utiliser une connexion web permet une meilleure intégration dans FME mais, dans certains cas, vous pourriez souhaiter utiliser une des autres sources.

Connexion web: - utiliser une connexion RabbitMQConnector enregistrée dans les connexions aux bases de données.
Intégré - informations d'identification intégrées comme paramètres du Transformer

Compte

Disponible lorsque la source d'accréditation est Connexion web. Pour créer une connexion RabbitMQ, cliquez sur la liste déroulante 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

Hôte	Point final du courtier RabbitMQConnector.
Hôte virtuel	Le nom de l'hôte virtuel utilisé pour les courtiers multi-locataires. La valeur par défaut est /.
Port courtier	Port de connexion au courtier. La valeur par défaut est 5672.
Port web	Le port pour se connecter à l'API HTTP RabbitMQ. Il s'agit du même port que celui utilisé pour l'interface web d'administration. La valeur par défaut est 15672
Activer SSL/TLS	Utilisation ou non d'une connexion sécurisée lors de la connexion au courtier.
Vérifier les certificats	Vérifier ou non les certificats SSL/TLS. Ne choisir Non que si des erreurs de certificat sont attendues.
Nom d'utilisateur, Mot de passe	Le nom d'utilisateur et le mot de passe à utiliser lors de la connexion au courtier.

Requête

Action

Le type d'opération à effectuer. Les choix possibles sont :

Accusé de réception
Compte des message
Réception
Envoi

Paramètres - Action Accusé de réception

Options d'accusé de réception

Identifiant du connecteur de réception	L'attribut _connector_id reçu de l'action de réception. Utilisé pour déterminer le message à acquitter.
Tag de livraison	L'attribut _delivery_tag reçu de l'action Recevoir. Utilisé pour déterminer le message dont accuser réception.
Messages multiples	Si oui, accuse réception de tous les messages avant le message courant.

Paramètres - Action Compte des messages

Options Compte des message

File d'attente

La file d'attente depuis laquelle compter les messages en attente.

Paramètres - Réception

Routage

Type d'échange	Echange Répartition: Les messages sont envoyés à toutes les queues liées à l'échange. Direct: Les messages sont envoyés à toutes les files d'attente liées à l'échange via la clé de routage. Topic: Les messages sont envoyés aux files d'attente liées à une clé de routage via un modèle.
Echange	Le nom de l'échange consiste en une séquence non vide des caractères : lettres, chiffres, traits d'union, underscore, points ou deux points.
Clé de routage	Nom utilisé pour router un message d'échanges à des fils d'attente.
File d'attente	Le nom de la file d'attente. S'il est vide, le courtier créera un nom de file d'attente unique.
Type de file d'attente	Type de file d'attente RabbitMQ : Classique (par défaut) Quorum Flux

Options de réception

Mode de réception

Deux options de réception de messages sont disponibles :

Flux : Le connecteur continue à recevoir des messages indéfiniment. La traduction doit être interrompue pour arrêter la réception.
Lots : Seul un nombre donné de messages sont reçus avant que la connexion soit close.

Taille des lots

La méthode Lots spécifie le nombre de messages à lire par lot.

Propriétés avancées

Accusé de réception automatique	Trois modes d'accusé de réception sont disponibles. Par défaut : Non. Non, les messages doivent être accusés dans un autre Transformer. Le canal vers le courtier restera ouvert jusqu'à ce que les messages soient acquittés. Utilisez les attributs _connector_id et _delivery_tag sortis dans le Transformer d'accusé de réception. Côté serveur : le courtier enverra des messages sans attendre d'accusé de réception en retour. Si vous utilisez le mode de réception par lots avec une taille de lot inférieure au nombre de messages en file d'attente, les messages restants seront rejetés. Pour plus d'informations sur la sécurité des données avec l'acquittement automatique de RabbitMQ, voir : https://www.rabbitmq.com/docs/confirms#acknowledgement-modes Côté client : le Transformer enverra automatiquement un accusé de réception à chaque message. Cette option est désactivée si le type de file d'attente est Stream, car les messages consommés feront toujours l'objet d'un accusé de réception.
Déclarer l'échange	Spécifie si l'échange doit être déclaré.
Propriétés d'échange	Propriétés à appliquer à l'échange Auto_Delete: l'échange est supprimé après que le consommateur se déconnecte ou annule. Durable: Survit aux redémarrages du courtier. Si cette option n'est pas sélectionnée, l'échange est transitoire. Un échange transitoire est supprimé au redémarrage. Les métadonnées d'un échange durable sont stockées sur le disque, tandis que les métadonnées d'un échange transitoire sont stockées en mémoire.
Propriétés de la fil d'attente	Propriétés à appliquer à la file d'attente lorsque le type de file d'attente est Classique : Auto_Delete: la queue est supprimée après que le consommateur se déconnecte ou annule. Durable: Survit aux redémarrages du broker. Si cette option n'est pas sélectionnée, la file d'attente est transitoire. Un message de file d'attente transitoire est supprimé au redémarrage. Les métadonnées d'une file d'attente durable sont stockées sur le disque, tandis que les métadonnées d'une file d'attente transitoire sont stockées en mémoire. Depuis fpkg-rabbitmq 3.1.0, les nouvelles files d'attente classiques sur RabbitMQ 4.0+ doivent être durables. Pour plus d'informations sur les queues RabbitMQ voir : https://www.rabbitmq.com/queues.html
Méthode de décalage	Si le type de file d'attente est Stream, spécifier où dans le flux commencer la lecture des messages. Premier : démarre la lecture des messages depuis le premier message du flux. Dernier : démarre la lecture des messages depuis le dernier message du flux. Suivant : attente de messages entrants. Valeur : Voir Valeur de décalage. Horodatage : Voir Horodatage de décalage.
Valeur de décalage	Si la Méthode de décalage est Valeur, spécifier soit un entier représentant un décalage d'un message existant dans la file d'attente du flux, soit une chaîne « Intervalle » qui commence par un entier et se termine par une unité valide (Y,M,D,h,m,s). Voir les options de Décalage et d'Intervalle sur https://www.rabbitmq.com/docs/streams#consuming.
Horodatage de décalage	Si la Méthode de décalage est Horodatage, spécifier une date et une heure représentant un point dans le temps à partir duquel la lecture des messages doit commencer. Cette date et cette heure doivent être spécifiées en temps universel coordonné (UTC). Voir l'option Horodatage sur https://www.rabbitmq.com/docs/streams#consuming pour plus de détails.
Propriétés de flux	Propriétés à appliquer à la file d'attente quand Type de file d'attente est Flux. x-max-age: Définit l'âge maximum du flux. x-max-length-bytes: Sets the maximum size of the stream in bytes. x-stream-max-segment-size-bytes : Définit la taille maximale d'un fichier de segment de flux en octets. Si une file d'attente existe déjà, les propriétés spécifiées doivent correspondre aux propriétés existantes. Pour plus d'informations sur les propriétés de flux RabbitMQ : https://www.rabbitmq.com/docs/streams#declaring.

Paramètres - Envoi

Routage

Type d'échange

Echange

Répartition: Les messages sont envoyés à toutes les queues liées à l'échange.
Direct: Les messages sont envoyés à toutes les files d'attente liées à l'échange via la clé de routage.
Topic: Les messages sont envoyés aux files d'attente liées à une clé de routage via un modèle.

Echange

Le nom de l'échange consiste en une séquence non vide des caractères : lettres, chiffres, traits d'union, underscore, points ou deux points.

Clé de routage

Nom utilisé pour router un message d'échanges à des fils d'attente.

Si Type d'échange est Direct et que l'Echange est vide, Déclarer la file d'attente doit être Oui et la Clé de démarrage doit être identique à la File d'attente.

Options d'envoi

Payload	Le contenu du message. Il s'agit souvent de JSON, mais il peut s'agir de n'importe quelle chaîne, valeur binaire, entière ou à virgule flottante.
Mode de livraison	Par défaut: Les messages sont perdus après que le courtier redémarre. Persistent: Les messages sont stockés sur le disque et persistent au redémarrage du courtier.

Propriétés avancées

Déclarer l'échange	Spécifie si l'échange doit être déclaré.
Propriétés d'échange	Propriétés à appliquer à l'échange Auto_Delete: l'échange est supprimé après que le consommateur se déconnecte ou annule. Durable : Survit aux redémarrages du courtier. Si cette option n'est pas sélectionnée, l'échange est transitoire. Un échange transitoire est supprimé au redémarrage. Les métadonnées d'un échange durable sont stockées sur le disque, tandis que les métadonnées d'un échange transitoire sont stockées en mémoire.
Déclarer la queue	Spécifie si la queue doit être déclarée.
File d'attente	Nom de la fil d'attente à utiliser.
Type de file d'attente	Type de file d'attente RabbitMQ : Classique (par défaut) Quorum Flux
Propriétés de la fil d'attente	Propriétés à appliquer à la file d'attente lorsque le type de file d'attente est Classique : Auto_Delete: la queue est supprimée après que le consommateur se déconnecte ou annule. Durable: Survit aux redémarrages du broker. Si cette option n'est pas sélectionnée, la file d'attente est transitoire. Un message de file d'attente transitoire est supprimé au redémarrage. Les métadonnées d'une file d'attente durable sont stockées sur le disque, tandis que les métadonnées d'une file d'attente transitoire sont stockées en mémoire. Depuis fpkg-rabbitmq 3.1.0, les nouvelles files d'attente classiques sur RabbitMQ 4.0+ doivent être durables. Pour plus d'informations sur les queues RabbitMQ voir : https://www.rabbitmq.com/queues.html
Propriétés du message	Propriétés supplémentaires du message paramétrables. Les touches suivantes sont valables : content_type content_encoding priority correlation_id reply_to expiration message_id timestamp type user_id app_id cluster_id
Propriétés de flux	Propriétés à appliquer à la file d'attente quand Type de file d'attente est Flux. x-max-age: Définit l'âge maximum du flux. x-max-length-bytes: Sets the maximum size of the stream in bytes. x-stream-max-segment-size-bytes : Définit la taille maximale d'un fichier de segment de flux en octets. Si une file d'attente existe déjà, les propriétés spécifiées doivent correspondre aux propriétés existantes. Pour plus d'informations sur les propriétés de flux RabbitMQ : https://www.rabbitmq.com/docs/streams#declaring.

Attributs en sortie

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.

_delivery_tag	Utilisé pour identifier les messages de l'accusé de réception.
_payload	La charge utile du message. Chaîne UTF-8 si possible à décoder, sinon binaire ou numérique.
_consumer_tag	Utilisé pour ientifier le consommateur.
_exchange	L'échange par lequel le message a été acheminé.
_headers	Liste des pairs nom/valeur de l'en-tête du message.
_properties	Liste des pairs nom/valeur des propriétés supplémentaires du message.
_redelivered	Vrai si un message est délivré mais pas totalement accusé de réception et remis en file d'attente.
_routing_key	Clé de routage utilisée pour acheminer le message.

Définir des valeurs de paramètres

Définir les valeurs

Il existe plusieurs façons de définir une valeur à utiliser dans un Transformer. La plus simple consiste à saisir simplement une valeur ou une chaîne de caractères, qui peut inclure des fonctions de différents types telles que des références d'attributs, des fonctions mathématiques et de chaînes de caractères, et des paramètres traitement.

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.

Editeur de texte

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.

Éditeur arithmétique

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.

Types de contenu

Fonctions chaînes 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.
Fonctions mathématiques	Plusieurs fonctions sont disponibles dans les deux éditeurs.
Fonctions Date/heure	Les fonctions de dates et heures sont disponibles dans l'Editeur texte.
Opérateurs mathématiques	Ces opérateur sont disponibles dans l'éditeur arithmétique.
Fonctions d'entités	Elles retournent des valeurs spécifiques aux entités.
Paramètres FME	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

Outils de tableau

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 :

Ajouter une ligne
Supprimer une ligne
Déplacer la ligne en cours au dessus
Déplacer la ligne en cours en dessous
Déplacer la ligne en cours en haut de liste
Déplacer la ligne en cours en bas de liste

Couper, Copier et Coller

Activé une fois que vous avez cliqué sur un élément de ligne. Les choix comprennent :

Couper une ligne - supprime et copie dans le presse-papiers.
Copie une ligne dans le presse-papiers.
Colle une ligne depuis le presse-papiers.

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.

Comportement	Basé sur des entités
Stockage des entités	Non
Dépendances
Alias
Historique	Implémenté dans FME 2019.0

RabbitMQConnector

Cas d'utilisation courants

Configuration

Ports en entrée

Ports de sortie

Paramètres

Éditer les paramètres des Transformers

Références

FME Community