Ajouter la CDC de la base de données PostgreSQL en tant que source dans le hub en temps réel (préversion)

Cet article explique comment ajouter la capture des changements de données (CDC) de la base de données PostgreSQL en tant que source d’événements dans le hub En temps réel Fabric.

Le connecteur source de capture de données modifiées (CDC) de base de données PostgreSQL pour les Evenstreams Microsoft Fabric vous permet de capturer un instantané des données actuelles dans une base de données PostgreSQL. Le connecteur surveille et enregistre ensuite les modifications futures au niveau des lignes apportées à ces données.

Remarque

Le hub en temps réel est actuellement en mode aperçu.

Prérequis

• Accédez à un espace de travail Premium avec les autorisations Contributeur ou supérieures.

• Accès utilisateur inscrit dans la base de données PostgreSQL.

• CDC activée dans la base de données PostgreSQL.

  Si vous avez Azure Database pour PostgreSQL, suivez les étapes de la section suivante pour activer la CDC. Pour des informations détaillées, consultez Réplication logique et décodage logique - Serveur flexible Azure Database pour PostgreSQL.

  Pour les autres bases de données PostgreSQL, consultez le connecteur Debezium pour PostgreSQL :: Documentation de Debezium.

Remarque

La CDC de plusieurs tables n’est pas prise en charge.

Activer la CDC dans votre Azure Database pour PostgreSQL

Pour activer la CDC dans votre Azure Database pour PostgreSQL, suivez ces étapes en fonction de votre type de déploiement.

Serveur unique Azure Database pour PostgreSQL

1. Accédez à la page Réplication du portail Azure.

2. Remplacez la règle de réplication par Logique.

   

Azure Database pour PostgreSQL - Serveur flexible

1. Sur la page de votre serveur Azure Database pour PostgreSQL, sélectionnez Paramètres du serveur dans le menu de navigation.

2. Sur la page Paramètres du serveur :

   • Définir wal_level sur logique.

   • Mettez à jour le max_worker_processes sur au moins 16.

     

3. Enregistrez les modifications et redémarrez le serveur.

4. Vérifiez que votre instance de serveur flexible Azure Database pour PostgreSQL autorise le trafic réseau public.

5. Accordez aux autorisations de réplication de l’utilisateur administrateur en exécutant l’instruction SQL suivante.

   ALTER ROLE <admin user> WITH REPLICATION;
   

Lancer une expérience Obtenir des événements

1. Passez à l’expérience Informations en temps réel dans Microsoft Fabric. Sélectionnez Microsoft Fabric dans la barre de navigation gauche, puis sélectionnez Informations en temps réel.

   

2. Sélectionnez Hub en temps réel dans la barre de navigation gauche.

   

3. Dans la page hub en temps réel, sélectionnez + Obtenir des événements dans le coin supérieur droit de la page.

   

Utilisez des instructions de la section Ajouter CDC de base de données PostgreSQL en tant que source.

Onglet Sources Microsoft

1. Dans le hub en temps réel, basculez vers l’onglet Sources Microsoft.

2. Dans la liste déroulante Source, sélectionnez PostgreSQL (CDC).

3. Pour Abonnement, sélectionnez un abonnement Azure qui possède le groupe de ressources avec votre compte Azure MySQL Database.

4. Pour Groupe de ressources, sélectionnez un groupe de ressources qui possède votre base de données.

5. Pour Région, sélectionnez un emplacement où se trouve votre base de données.

6. Maintenant, pointez avec la souris sur le nom de la source CDC de la base de données PostgreSQL que vous souhaitez connecter au hub en temps réel dans la liste des bases de données, puis sélectionnez le bouton Connecter, ou sélectionnez ... (points de suspension), puis le bouton Connecter.

   

   Pour configurer les informations de connexion, suivez les étapes de la section Ajouter la CDC d’Azure MySQL DB en tant que source. Ignorez la première étape de la sélection de CDC de la dB d’Azure MySQL en tant que type de source dans l’Assistant Obtenir les événements.

Ajoutez la CDC d’Azure Database pour PostgreSQL en tant que source

1. Dans l’écran Sélectionner une source de données, sélectionnez Azure DB pour PostgreSQL (CDC).

   

2. Dans la page Connecter, sélectionnez Accéder à la ressource pour naviguer vers la base de données Azure PostgreSQL. Sur la page Vue d’ensemble, notez le nom du serveur. Il se présente au format suivant : myazurepostgresqlserver.postgres.database.azure.com.

   

3. Sur la page Connecter, sélectionnez Nouvelle connexion.

   

4. Dans la section Paramètres de connexion, saisissez les informations suivantes :

   • Serveur : adresse du serveur de votre base de données PostgreSQL, par exemple my-pgsql-server.postgres.database.azure.com.

   • Base de données : nom de la base de données, par exemple my_database.

     

5. Faites défiler vers le bas et, dans la section Identifiants de connexion, suivez les étapes suivantes :

   1. Dans le champ Nom de la connexion, saisissez un nom pour la connexion.

   2. Pour le type d’authentification, sélectionnez De base.

      Remarque

      Actuellement, les Eventstreams Fabric prennent uniquement en charge l’authentification de base.

   3. Entrez le nom d'utilisateur et le mot de passe de la base de données.

   4. Sélectionnez Se connecter.

      

6. À présent, à la page Connecter, suivez ces étapes :

   1. Dans Table, saisissez un nom de table.

   2. Pour port, saisissez le numéro de port ou conservez la valeur par défaut : 5432.

   3. Pour le nom de l’Eventstream, saisissez un nom pour l’Eventstream. L’assistant crée un Eventstream avec la CDC de la base de données PostgreSQL sélectionnée comme source.

   4. Le nom du flux est généré automatiquement pour vous en ajoutant -stream au nom de l’Eventstream. Vous voyez ce flux sous l’onglet Flux de données du hub en temps réel lorsque l’assistant se termine.

   5. Sélectionnez Suivant au bas de la page.

      

7. À l’écran Vérifier et créer, vérifiez le résumé, puis sélectionnez Créer une source.

   

Afficher les détails du flux de données

1. Dans la page Vérifier et créer, si vous sélectionnez Ouvrir un Eventstream, l’Assistant ouvre l’Eventstream qu’il a créé pour vous avec la CDC de base de données PostgreSQL sélectionnée en tant que source. Pour fermer l'assistant, sélectionnez Fermer en bas de la page.

   

2. Dans le hub en temps réel, basculez vers l’onglet Flux de données du hub en temps réel. Actualisez la page. Vous devez voir le flux de données créé pour vous, comme illustré sur l’image suivante.

   

Contenu connexe

Pour en savoir plus sur l’utilisation de flux de données, consultez les articles suivants :

• Traitement des flux de données
• Analyse des flux de données
• Définir des alertes sur des flux de données