Référence du connecteur RabbitMQ
Bêta
Cette fonctionnalité est en Bêta. Les administrateurs du Workspace peuvent contrôler l'accès à cette fonctionnalité à partir de la page Previews . Consultez Gérer les aperçus Databricks.
Cette page contient la documentation de référence pour le connecteur RabbitMQ géré dans Lakeflow Connect.
Options du connecteur
Les options suivantes configurent la source RabbitMQ pour chaque table de destination dans le pipeline d'ingestion. Spécifiez ces options sous connector_options.rabbitmq_options dans votre définition de pipeline. Consultez Exemples pour obtenir des exemples de pipelines complets.
Option | Type | Par défaut | Description |
|---|---|---|---|
| Chaîne | — | (Obligatoire) Nom de la file classique RabbitMQ à consommer. |
Propriétés de connexion
Lorsque vous créez la connexion Unity Catalog RabbitMQ dans Catalog Explorer, vous devez spécifier les propriétés suivantes. Consultez Créer une connexion RabbitMQ pour connaître les étapes de création de connexion.
Propriété | Description |
|---|---|
Nom de la connexion | Un nom unique pour la connexion dans Unity Catalog. |
Type de connexion | Sélectionner RabbitMQ . |
Hôte | Le Hostname du broker RabbitMQ. |
Nom d'utilisateur | Le nom d’utilisateur utilisé pour l’authentification auprès du broker RabbitMQ. |
Mot de passe | Le mot de passe utilisé pour s'authentifier auprès du broker RabbitMQ. |
Hôte virtuel | L'hôte virtuel du broker RabbitMQ. L'hôte virtuel default est |
Port | Le port du broker RabbitMQ. Le port default est |
Schéma de table de destination
Le connecteur RabbitMQ écrit dans des tables de streaming (en mode ajout uniquement). Chaque table de destination contient le corps de message décodé et les colonnes de métadonnées RabbitMQ, y compris une colonne _redelivered qui est true pour les messages qui ont été livrés de nouveau après un accusé de réception infructueux.