Change Tracking vous permet de créer des groupes de consommateurs. La création de plusieurs groupes vous permet de consommer les données d'une même source à plusieurs reprises, réduisant ainsi le coût d'utilisation de Change Tracking.
Prérequis
Vous avez créé une instance de suivi des modifications et son statut est Normal. Pour plus d'informations, consultez la rubrique Présentation des scénarios de suivi des modifications.
Notes d'utilisation
Si une seule ligne de données à consommer dépasse 16 Mo, le client consommateur peut rencontrer une erreur de mémoire insuffisante (OOM).
Vous pouvez créer au maximum 20 groupes de consommateurs pour une instance de suivi des modifications afin de permettre la consommation répétée des données.
Chaque groupe de consommateurs ne prend en charge qu'un seul consommateur, qui consomme toutes les données du groupe.
Le changement de module DStore ou de client peut entraîner une duplication des données.
Procédure
-
Accédez à la page Tâches de suivi des modifications via l'une des méthodes suivantes, puis sélectionnez la région dans laquelle se trouve l'instance de suivi des modifications.
Console DTS
Connectez-vous à la console DTS.
Dans le volet de navigation de gauche, cliquez sur Suivi des modifications.
Dans le coin supérieur gauche de la page, sélectionnez la région dans laquelle se trouve l'instance de suivi des modifications.
Console DMS
RemarqueLes opérations réelles peuvent varier selon le mode et la disposition de la console DMS. Pour plus d'informations, consultez les rubriques Console en mode simple et Personnaliser la disposition et le style de la console DMS.
Connectez-vous à la console DMS.
Dans la barre de navigation supérieure, placez le pointeur sur .
Dans la liste déroulante située à droite de Change Tracking Tasks, sélectionnez la région dans laquelle se trouve l'instance de suivi des modifications.
Recherchez l'instance de suivi des modifications cible et cliquez sur son ID d'instance.
Dans le volet de navigation de gauche, cliquez sur Consume Data.
Sur la page Consume Data, cliquez sur Add Consumer Group dans le coin supérieur gauche.
-
Dans la boîte de dialogue Add Consumer Group, configurez les paramètres suivants.
Paramètre
Description
Consumer Group Name
Nous vous recommandons d'utiliser un nom descriptif pour faciliter l'identification.
Account
Saisissez le compte pour le groupe de consommateurs.
-
Le nom du compte peut contenir des lettres majuscules, des lettres minuscules, des chiffres et des traits de soulignement (_).
-
Le nom du compte doit comporter entre 1 et 16 caractères.
Password
Saisissez le mot de passe du compte.
-
Le mot de passe doit contenir des caractères appartenant à au moins deux des catégories suivantes : lettres majuscules, lettres minuscules, chiffres et caractères spéciaux.
-
Le mot de passe doit comporter entre 8 et 32 caractères.
Confirm Password
Saisissez à nouveau le même mot de passe.
-
Cliquez sur OK.
Étapes suivantes
Après avoir ajouté le groupe de consommateurs, sélectionnez une méthode de consommation des données en fonction du type de base de données source et du type de client consommateur.
|
Méthode de consommation |
Types de bases de données applicables |
Description |
|
Consommer les données d'une instance PolarDB-X 1,0 à l'aide d'un SDK |
PolarDB-X 1.0, DMS LogicDB |
Cette méthode concerne les instances de suivi des modifications dont la base de données source est PolarDB-X 1.0 ou DMS LogicDB. Remarque
Il s'agit de la seule méthode de consommation prise en charge pour les instances de suivi des modifications dont la base de données source est PolarDB-X 1.0 ou DMS LogicDB. |
|
MySQL, PolarDB for MySQL, PostgreSQL, Oracle, PolarDB (Compatible with Oracle), PolarDB for PostgreSQL, PolarDB-X 2.0 |
Cette méthode convient à la plupart des scénarios. Remarque
Cette méthode est recommandée pour tous les types de bases de données pris en charge. |
|
|
Cette méthode est destinée aux scénarios utilisant le framework de traitement de flux Apache Flink. |
||
|
Cette méthode s'adresse aux utilisateurs disposant de leur propre client Kafka et capables de développer à partir du code source. |