La fonctionnalité de souscription aux données vous permet de vous abonner en temps réel aux modifications incrémentielles des données d'une base de données source. Elle prend en charge des cas d'utilisation tels que la mise à jour légère du cache, le découplage asynchrone des activités métier et la synchronisation des données en temps réel impliquant une logique ETL. Cette rubrique explique comment créer une tâche de souscription aux données pour une instance RDS for MySQL.
Prérequis
-
Vous avez créé une instance RDS for MySQL.
RemarquePour obtenir des informations sur les versions prises en charge, consultez la section Présentation des solutions de souscription.
Vous avez créé un Virtual Private Cloud (VPC) et un vSwitch pour l'instance de souscription aux données.
Limites
Type | Description |
Limites de la base de données source |
|
Autres limites |
|
Procédure
-
Accédez à la page Change Tracking Tasks en utilisant 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 Change Tracking.
Dans le coin supérieur gauche de la page, sélectionnez la région dans laquelle se trouve l'instance change tracking.
Console DMS
RemarqueLes opérations réelles peuvent varier en fonction du mode et de 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.
Cliquez sur Create Task pour accéder à la page de configuration de la tâche.
-
Configurez les paramètres dans les sections Source Database et Consumer Network Type.
AvertissementAprès avoir spécifié l'instance de la base de données source, nous vous recommandons de lire les Limits affichées dans la partie supérieure de la page. À défaut, la tâche risque d'échouer ou les données suivies ne pourront pas être consommées.
Section
Parameter
Description
N/A
Task Name
Le nom de la tâche de suivi des modifications. DTS attribue automatiquement un nom à la tâche. Nous vous recommandons de spécifier un nom descriptif permettant d'identifier facilement la tâche. Il n'est pas nécessaire d'utiliser un nom de tâche unique.
Source Database
Select Existing Connection
Si vous utilisez une instance de base de données enregistrée auprès de DTS, sélectionnez l'instance dans la liste déroulante. DTS renseigne automatiquement les paramètres de base de données suivants pour l'instance. Pour plus d'informations, consultez la rubrique Gérer les connexions aux bases de données.
RemarqueDans la console DMS, vous pouvez sélectionner l'instance de base de données dans la liste déroulante Select a DMS database instance.
Si vous ne parvenez pas à enregistrer l'instance auprès de DTS ou si vous n'avez pas besoin d'utiliser l'instance enregistrée auprès de DTS, vous devez configurer les informations de base de données suivantes.
Database Type
Sélectionnez MySQL.
Access Method
Sélectionnez Alibaba Cloud Instance.
Instance Region
Sélectionnez la région dans laquelle se trouve l'instance RDS for MySQL.
Replicate Data Across Alibaba Cloud Accounts
Pour ce tutoriel, sélectionnez No.
ImportantSi vous devez accéder aux ressources de la base de données source entre différents comptes (en sélectionnant Yes), vous devez configurer l'autorisation RAM pour le compte Alibaba Cloud utilisé pour créer la tâche DTS. Vous devez également saisir le Alibaba Cloud Account et le RAM Role Name. Pour obtenir des instructions, consultez la rubrique Configurer l'autorisation RAM pour les tâches intercomptes.
RDS Instance ID
Sélectionnez l'ID de l'instance RDS for MySQL.
Database Account
Saisissez un read-only account pour la base de données RDS for MySQL, ou un compte personnalisé disposant des autorisations REPLICATION CLIENT, REPLICATION SLAVE, SHOW VIEW et SELECT.
Database Password
Le mot de passe utilisé pour accéder à l'instance de base de données.
Encryption
Indique s'il faut chiffrer la connexion à l'instance de base de données. Sélectionnez Non-encrypted ou SSL-encrypted selon vos besoins. Si vous sélectionnez SSL-encrypted, vous devez activer le chiffrement SSL pour l'instance ApsaraDB RDS for MySQL avant de configurer la tâche de suivi des modifications. Pour plus d'informations, consultez la rubrique Configurer la fonctionnalité de chiffrement SSL.
Consumer Network Type
Network Type
La valeur du paramètre Network Type est fixée à VPC. Vous devez sélectionner un VPC et un vSwitch. Pour plus d'informations, consultez la rubrique VPCs.
RemarqueUne fois la tâche de suivi des modifications configurée, vous ne pouvez pas modifier les paramètres de la section Consumer Network Type.
Si votre client de suivi des modifications est déployé dans un VPC, nous vous recommandons de sélectionner le même VPC et le même vSwitch connectés au client.
Si vous suivez les modifications des données via des réseaux internes, la latence réseau est minimale.
-
Dans la partie inférieure de la page, cliquez sur Test Connectivity and Proceed.
RemarqueAssurez-vous que les plages CIDR des serveurs DTS peuvent être ajoutées automatiquement ou manuellement aux paramètres de sécurité des bases de données source et de destination afin d'autoriser l'accès depuis les serveurs DTS. Pour plus d'informations, consultez la rubrique Ajouter les adresses IP des serveurs DTS à la liste d'autorisation.
Si la base de données source est une base de données auto-gérée et que son Access Method n'est pas défini sur Alibaba Cloud Instance, cliquez sur Test Connectivity dans la boîte de dialogue CIDR Blocks of DTS Servers.
-
Configurez les objets pour le suivi des modifications.
-
Sur la page Configure Objects, configurez les objets pour le suivi des modifications.
Parameter
Description
Data Change Types
Les options Data Change Types sont sélectionnées par défaut et ne peuvent pas être modifiées.
Data Update
DTS suit les mises à jour des données des objets sélectionnés, y compris les opérations INSERT, DELETE et UPDATE.
Schema Update
DTS suit les opérations de création, de suppression et de modification effectuées sur tous les schémas d'objets de l'instance source. Vous devez utiliser le client de suivi des modifications pour filtrer les données à suivre.
Source Objects
Sélectionnez un ou plusieurs objets dans la section Source Objects et cliquez sur l'icône
pour ajouter les objets à la section Selected Objects. RemarqueVous pouvez sélectionner des tables ou des bases de données comme objets pour le suivi des modifications.
Si vous sélectionnez une base de données comme objet, DTS suit les données incrémentielles de tous les objets, y compris les nouveaux objets de la base de données.
Si vous sélectionnez une table comme objet, DTS suit uniquement les données incrémentielles de cette table. Dans ce cas, si vous souhaitez suivre les modifications des données d'une autre table, vous devez ajouter la table à la liste des objets. Pour plus d'informations, consultez la rubrique Modifier les objets pour le suivi des modifications.
-
Cliquez sur Next: Advanced Settings pour configurer les paramètres avancés.
Parameter
Description
Dedicated Cluster for Task Scheduling
Par défaut, DTS planifie la tâche sur un cluster partagé. Vous n'avez pas besoin de configurer ce paramètre. Vous pouvez acheter des clusters dédiés avec des spécifications spécifiques pour exécuter les tâches de suivi des modifications DTS. Pour plus d'informations, consultez la rubrique Qu'est-ce qu'un cluster dédié DTS ?.
Retry Time for Failed Connections
La plage de temps de nouvelle tentative en cas d'échec des connexions. Si la tâche de suivi des modifications échoue, DTS tente immédiatement une reconnexion dans cette plage de temps. Valeurs valides : 10 à 1440. Unité : minutes. Valeur par défaut : 720. Nous vous recommandons de définir le paramètre sur une valeur supérieure à 30. Si DTS se reconnecte à l'instance de la base de données source dans la plage de temps spécifiée, DTS reprend la tâche de suivi des modifications. Sinon, la tâche de suivi des modifications échoue.
RemarqueSi plusieurs tâches de suivi des modifications sont configurées pour une instance de base de données, la plage de temps de nouvelle tentative la plus courte est prioritaire. Par exemple, les tâches A et B sont configurées pour la même instance de base de données. La tâche A est configurée avec une plage de temps de nouvelle tentative de 30 minutes et la tâche B avec une plage de 60 minutes. Dans ce cas, la plage de 30 minutes est prioritaire.
Lorsque DTS tente une reconnexion, des frais sont facturés. Nous vous recommandons de spécifier la plage de temps de nouvelle tentative en fonction de vos exigences métier ou de libérer l'instance DTS dès que possible après la libération de l'instance de la base de données source.
Retry Time for Other Issues
La plage de temps de nouvelle tentative pour les autres problèmes. Par exemple, si les opérations DDL ou DML échouent après le démarrage de la tâche de suivi des modifications, DTS retente immédiatement les opérations dans la plage de temps de nouvelle tentative. Valeurs valides : 1 à 1440. Unité : minutes. Valeur par défaut : 10. Nous vous recommandons de définir le paramètre sur une valeur supérieure à 10. Si les opérations ayant échoué sont exécutées avec succès dans la plage de temps de nouvelle tentative spécifiée, DTS reprend la tâche de suivi des modifications. Sinon, la tâche de suivi des modifications échoue.
ImportantLa valeur du paramètre Retry Time for Other Issues doit être inférieure à la valeur du paramètre Retry Time for Failed Connections.
Whether to delete SQL operations on heartbeat tables of forward and reverse tasks
Choisissez d'écrire ou non les informations SQL de pulsation dans la base de données source lorsque l'instance DTS est en cours d'exécution.
-
Yes : Les informations SQL de pulsation ne sont pas écrites dans la base de données source. Cela peut entraîner un retard signalé par l'instance DTS.
-
No : Écrit les informations SQL de pulsation dans la base de données source. Cela peut interférer avec des fonctionnalités telles que la sauvegarde physique et le clonage de la base de données source.
Environment Tag
Vous pouvez sélectionner un tag d'environnement pour identifier l'instance selon vos besoins. Pour ce tutoriel, aucune sélection n'est nécessaire.
Monitoring and Alerting
Indique s'il faut activer les alertes pour la tâche de suivi des modifications. Si les alertes sont configurées et que la tâche échoue ou que la latence dépasse le seuil, des notifications d'alerte sont envoyées. Valeurs valides :
No : n'active pas les alertes.
Yes : active les alertes. Dans ce cas, vous devez également configurer le seuil d'alerte et les paramètres de notification d'alerte. Pour plus d'informations, consultez la rubrique Configurer les alertes lors de la configuration de l'instance.
-
-
Dans la partie inférieure de la page, cliquez sur Next: Save Task Settings and Precheck.
Pour afficher les paramètres à spécifier lors de l'appel de l'opération API pertinente pour configurer la tâche DTS, placez le pointeur sur Next: Save Task Settings and Precheck et cliquez sur Preview OpenAPI parameters.
Si vous n'avez pas besoin d'afficher les paramètres ou si vous les avez déjà consultés, cliquez sur Next: Save Task Settings and Precheck dans la partie inférieure de la page.
RemarqueAvant de pouvoir démarrer la tâche de suivi des modifications, DTS effectue une vérification préalable. Vous ne pouvez démarrer la tâche de suivi des modifications qu'après réussite de cette vérification.
Si la tâche ne réussit pas la vérification préalable, cliquez sur View Details à côté de chaque élément ayant échoué. Après avoir résolu les problèmes en vous basant sur le message d'erreur, vous pouvez relancer une vérification préalable.
-
Si une alerte est générée pour un élément lors de la vérification préalable, effectuez les opérations suivantes selon le scénario :
Si un élément d'alerte ne peut pas être ignoré, cliquez sur View Details à côté de l'élément ayant échoué et résolvez les problèmes. Ensuite, relancez une vérification préalable.
Si l'élément d'alerte peut être ignoré, cliquez sur Confirm Alert Details. Dans la boîte de dialogue View Details, cliquez sur Ignore. Dans le message qui s'affiche, cliquez sur OK. Ensuite, cliquez sur Precheck Again pour relancer une vérification préalable. Si vous ignorez l'élément d'alerte, des incohérences de données peuvent survenir et votre activité métier peut être exposée à des risques potentiels.
-
Achetez l'instance.
Attendez que le Success Rate atteigne 100%. Ensuite, cliquez sur Next: Purchase Instance.
-
Sur la page Purchase, spécifiez la méthode de facturation de l'instance de suivi des modifications. Le tableau suivant décrit les paramètres.
Parameter
Description
Méthode de facturation
Abonnement : Vous payez votre abonnement lors de la création d'une instance. La méthode de facturation par abonnement est plus économique que la méthode de paiement à l'utilisation pour une utilisation à long terme. Des prix plus bas vous sont proposés pour des durées d'abonnement plus longues.
Paiement à l'utilisation : Une instance en paiement à l'utilisation est facturée à l'heure. Nous vous recommandons de sélectionner la méthode de facturation par paiement à l'utilisation pour une utilisation à court terme. Si vous n'avez plus besoin d'une instance en paiement à l'utilisation, vous pouvez la libérer pour réduire les coûts.
Resource Group Settings
Le groupe de ressources auquel appartient l'instance. Valeur par défaut : default resource group. Pour plus d'informations, consultez la rubrique Qu'est-ce que Resource Management ?
Billing Type of Change Tracking Instance
Si vous sélectionnez la méthode de facturation par abonnement, vous ne pouvez sélectionner que Frais de configuration au tarif plein (sans frais de trafic de données) pour le paramètre Billing Type of Change Tracking Instance.
Subscription Duration
Si vous sélectionnez la méthode de facturation par abonnement, définissez la durée de l'abonnement et le nombre d'instances que vous souhaitez créer. La durée de l'abonnement peut être de un à neuf mois, un an, deux ans, trois ans ou cinq ans.
RemarqueCe paramètre est disponible uniquement si vous sélectionnez la méthode de facturation Subscription.
Lisez et acceptez les Data Transmission Service (Pay-as-you-go) Service Terms.
Cliquez sur Buy and Start pour démarrer la tâche de suivi des modifications. Vous pouvez consulter la progression de la tâche dans la liste des tâches.
Étapes suivantes
Une fois la tâche de souscription en cours d'exécution, créez un consumer group et choisissez une méthode de consommation des données pour votre client.