Ajouter la CDC Azure Cosmos DB en tant que source dans le hub en temps réel

Cet article explique comment ajouter la capture des changements de données Azure Cosmos DB for NoSQL (CDC) en tant que source de l’événement dans le hub Fabric en temps réel.

Le connecteur source de la capture des changements de données (CDC) Azure Cosmos DB vous permet de capturer un instantané des données actuelles dans une base de données Azure Cosmos DB. Le connecteur surveille et enregistre ensuite les modifications futures au niveau des lignes apportées à ces données. Une fois les modifications capturées dans un flux, vous pouvez traiter ces données CDC en temps réel et les envoyer à différentes destinations au sein de Fabric pour un traitement ou une analyse plus approfondis.

Prérequis

• Accès à un espace de travail en mode licence de capacité Fabric ou en mode licence d’évaluation avec des autorisations Collaborateur ou supérieures.
• Accédez à un compte Azure Cosmos DB for NoSQL et à la base de données.
• Votre base de données Azure Cosmos DB for NoSQL doit être accessible au public et ne doit pas se trouver derrière un pare-feu ou être sécurisée dans un réseau virtuel.
• Si vous n’avez pas de flux d’événements, créez un flux d’événements.

Obtenir les détails de connexion à partir du portail Azure

Les étiquettes des éléments que vous devez collecter à partir du portail Azure sont affichées dans les étapes suivantes. Vous avez toujours besoin de l’URI de point de terminaison, dans un format tel que https://<account>.<api>.azure.com:<port>/, de la clé primaire et des ID de base de données et d’article pour lesquelles vous souhaitez collecter des données.

Remarque

La CDC Azure Cosmos DB for NoSQL utilise le dernier mode de version du flux de modification d’Azure Cosmos DB. Il capture les modifications apportées aux enregistrements dans la dernière version. Notez que les suppressions ne sont pas capturées avec ce mode.

1. Sur la page du portail Azure pour votre compte Azure Cosmos DB, sélectionnez Clés sous Paramètres dans le volet de navigation de gauche.

2. Sur la page Clés, copiez l’URI et les valeurs de clé primaire à utiliser pour configurer la connexion eventstream.

   

3. Sur la page de présentation du portail Azure de votre compte Azure Cosmos DB, notez l’ID de base de données et d’article pour lequel vous souhaitez collecter des données.

   

Obtenir des événements à partir d’une CDC Azure Cosmos DB

Vous pouvez obtenir des événements à partir d’une CDC Azure Cosmos DB dans un hub en temps réel de l’une des façons suivantes :

• Utilisation de l’expérience Ajouter une source
• En utilisant la page Sources Microsoft

Page Sources de données

1. Connectez-vous à Microsoft Fabric.

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

3. Sur la page Hub en temps réel, sélectionnez + Sources de données sous Se connecter à dans le menu de navigation de gauche. Vous pouvez également accéder à la page Sources de données à partir des pages Tous les flux de données ou Mes flux de données en sélectionnant le bouton + Se connecter à la source de données dans le coin supérieur droit.

   

Suivez les instructions de la section Ajouter CDC azure Cosmos DB en tant que source.

Page Sources Microsoft

1. Dans Hub en temps réel, sélectionnez Sources Microsoft.

2. Dans la liste déroulante Source, sélectionnez (CDC) Azure Cosmos DB.

3. Pour l’abonnement, sélectionnez un abonnement Azure qui possède le groupe de ressources avec votre compte Cosmos DB.

4. Dans Groupe de ressources, sélectionnez un groupe de ressources pour votre compte Cosmos DB.

5. Pour Région, sélectionnez un emplacement où se trouve votre Cosmos DB.

6. Maintenant, déplacez la souris sur le nom de la source CDC Cosmos DB 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 Azure Cosmos DB en tant que source. Ignorez la première étape de la sélection de la capture des changements de données Azure Cosmos DB comme type de source dans l’assistant Ajouter une source.

Ajouter la CDC Azure Cosmos DB en tant que source

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

   

2. Dans la section Paramètres de connexion, spécifiez le point de terminaison Cosmos DB. Entrez l’URI ou le point de terminaison de votre compte Cosmos DB que vous avez copié à partir du Portail Azure.

   

3. Déroulez les Options avancées et procédez comme suit :

   1. Pour le Nombre de nouvelles tentatives, spécifiez le nombre maximum de fois que le connecteur doit retransmettre une requête à la base de données Cosmos DB si la requête échoue à cause d’une erreur récupérable.

   2. Pour Activer le transfert de la fonction AVERAGE, spécifiez si le connecteur doit transférer la fonction d’agrégation AVG vers la base de données Cosmos DB.

   3. Pour Activer le transfert de la fonction SORT vers plusieurs colonnes, spécifiez si le connecteur doit permettre à plusieurs colonnes d’être transférées vers la base de données Cosmos DB lorsqu’elles sont spécifiées dans la clause ORDER BY de la requête SQL.

      

4. Faites défiler vers le bas et, dans la section Identifiants de connexion, procédez comme suit :

   1. Sélectionnez une connexion existante et conservez l’option Créer une connexion par défaut.
   2. Pour créer une connexion, entrez les valeurs suivantes :

      1. Pour Nom de connexion, entrez un nom de connexion.

      2. Pour Type d’authentification, sélectionnez Clé de compte.

      3. Pour Clé de compte, entrez la valeur de clé que vous avez enregistrée précédemment.

      4. Sélectionnez Connecter.

         

5. À présent, sur la page Connecter, procédez comme suit :

   1. Spécifiez l’ID de conteneur du conteneur dans votre compte Azure Cosmos DB.

   2. Dans la section Détails du flux à droite, sélectionnez l’Espace de travail Fabric dans lequel vous souhaitez enregistrer le flux d’évènement que l’Assistant va créer.

   3. Pour nom du eventstream, saisissez un nom pour l’eventstream. L’assistant crée un eventstream avec la CDC Azure Cosmos DB 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 pouvez voir ce flux sur la page Tous les flux de données du hub en temps réel lorsque l’assistant se termine.

   5. Cliquez sur Suivant.

      

6. Dans l’écran Vérifier + Se connecter, vérifier 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 + Se connecter, si vous sélectionnez Ouvrir un flux d’événements, l’assistant ouvre le flux d’événements qu’il a créé pour vous avec la capture des changements de données Azure Cosmos DB sélectionnée comme source. Pour fermer l’assistant, sélectionnez Fermer ou X* dans le coin supérieur droit de la page.

   

2. Dans hub en temps réel, sélectionnez Tous les flux de données. Pour afficher le nouveau flux de données, actualisez la page Tous les flux de données.

   

   Pour obtenir des étapes détaillées, consultez Afficher les détails des flux de données dans le hub En temps réel de Fabric.

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