Réplication de données d'Autonomous Transaction Processing vers Apache Kafka
Découvrez comment configurer OCI GoldenGate pour répliquer des données d'Autonomous Transaction Processing vers Apache Kafka.
Présentation
A l'aide d'OCI GoldenGate, vous pouvez répliquer des données d'Autonomous Database vers une cible Big Data, comme Apache Kafka. Ce démarrage rapide explique comment configurer un déploiement OCI GoldenGate, des connexions source et cible, et des processus de réplication.
Avant de commencer
Pour mener à bien ce démarrage rapide, vous devez disposer des éléments suivants :
- Un réseau cloud virtuel avec le port 9092 (ou tout autre port utilisé pour le serveur de démarrage) ouvert dans les règles entrantes
- Une instance Autonomous Transaction Processing source
- Un noeud Apache Kafka cible
Configuration de l'environnement : Autonomous Transaction Processing
Si aucune base de données source n'est configurée pour la réplication, procédez comme suit afin de charger un schéma échantillon à utiliser avec le démarrage rapide. Ce démarrage rapide utilise Autonomous Transaction Processing pour la base de données source.
Pour configurer la base de données autonome source, procédez comme suit :
- Téléchargez et décompressez le schéma échantillon de base de données.
- Dans la console Oracle Cloud, sélectionnez votre instance Autonomous Transaction Processing (ATP) sur la page Bases de données autonomes afin de visualiser ses détails et d'accéder à Database Actions.
- Déverrouillez l'utilisateur GGADMIN :
- Cliquez sur Actions de base de données, puis sur Utilisateurs de base de données.
- Localisez GGADMIN, puis cliquez sur le menu en trois points et sélectionnez Modifier.
- Dans le panneau Modifier l'utilisateur, entrez le mot de passe GGADMIN, confirmez le mot de passe, puis désélectionnez Compte verrouillé.
- Cliquez sur Appliquer les modifications.
- Chargez le schéma échantillon source et les données :
- Activez la journalisation supplémentaire :
Tâche 1 : créer les ressources OCI GoldenGate
Cet exemple de démarrage rapide nécessite des déploiements et des connexions pour la source et la cible.
- Créez un déploiement Oracle pour l'instance Autonomous Transaction Processing source.
- Créez un déploiement Big Data pour le noeud Apache Kafka cible.
- Créez une connexion pour l'instance Autonomous Transaction Processing source.
- Créez une connexion pour le noeud Kafka cible.
- Créez une connexion à GoldenGate, puis affectez cette connexion au déploiement Oracle source.
- Affectez la connexion ATP au déploiement Oracle source.
- Affectez la connexion Kafka au déploiement Big Data cible.
Tâche 2 : ajouter le fichier Extract
- Sur la page Déploiements, sélectionnez le déploiement Autonomous Transaction Processing source.
- Sur la page des détails du déploiement, cliquez sur Lancer la console.
- Connectez-vous avec le nom utilisateur et le mot de passe de l'administrateur du déploiement source.
- Ajoutez des informations relatives aux transactions.
- Ajoutez un élément Extract.
Tâche 3 : ajoutez et exécutez Distribution Path.
- Si vous utilisez la banque d'informations d'identification GoldenGate, créez un utilisateur pour le chemin de distribution dans le déploiement Big Data cible. Sinon, passez à l'étape 3.
- Dans la console de déploiement ATP GoldenGate source, ajoutez une connexion de chemin pour l'utilisateur créé à l'étape 1.
- Dans la console de déploiement ATP source, ajoutez un chemin de distribution avec les valeurs suivantes :
- Dans la console de déploiement Big Data cible, vérifiez le fichier Receiver Path créé suite à la création de Distribution Path.
- Dans la console de déploiement Big Data cible, cliquez sur Receiver Service.
- Consultez les détails du chemin. Ce chemin a été créé à la suite de la création de Distribution Path à l'étape précédente.
Tâche 4 : ajouter le fichier Replicat
Vous revenez à la page Replicats, sur laquelle vous pouvez consulter les détails Replicat.
Tâche 5 : vérifier la réplication
Effectuez des mises à jour de l'instance Autonomous Transaction Processing source afin de vérifier la réplication vers Apache Kafka.