RabbitMQConnector

Catégories

Intégrations

Web

Exécution

Transformers liés

AzureQueueStorageConnector

GoogleCloudPubSubConnector

KafkaConnector

MQTTConnector

SQSConnector

Se connecte à un courtier AMQP 0-9-1. Supporte l'envoi (production) et la réception (consommation) de messages.

Aller à la configuration

Cas d'utilisation courants

  • Production de messages vers RabbitMQ
  • Agréger des données issues de RabbitMQ et autres flux de messages.
  • Interopérabilité avec des plateformes d'analyse Big Data

Configuration

Ports en 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, 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.

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.

Paramètres

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.

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.

Action

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

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

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

Attribut reçu de l'action de réception. Utilisé pour déterminer le message à acquitter.

Messages multiples

Si oui, accuse réception de tous les messages avant le message courant.

Options Compte des message

File d'attente

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

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.

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

Si Oui, les messages peuvent être acquittés dans un autre Transformer. Le canal vers le courtier restera ouvert jusqu'à ce que les messages soient acquittés. Utilisez l'attribut _connector_id sorti dans le Transformer d'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 fil

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

Pour plus d'informations sur les queues RabbitMQ voir : https://www.rabbitmq.com/queues.html

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.

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.

Propriétés de la fil d'attente

Propriétés à appliquer à la fil

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

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

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.

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

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.

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

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.

Références

Comportement

Basé sur des entités

Stockage des entités

Non
Dépendances  
Alias  
Historique Implémenté dans FME 2019.0

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.