Réplication de données d'Autonomous AI Transaction Processing vers Microsoft Fabric Eventstream

Avant de commencer

Pour mener à bien ce démarrage rapide, vous devez disposer des éléments suivants :

Instance Autonomous AI Transaction Processing source.
Un Microsoft Fabric Eventstream cible.

Configuration de l'environnement : Autonomous AI 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 le traitement des transactions par IA autonome pour la base de données source.

Pour configurer le traitement des transactions d'IA 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 AI Transaction Processing (ATP) sur la page des bases de données autonomes AI pour en visualiser les détails et accéder à Database Actions.
Déverrouillez l'utilisateur GGADMIN :
1. Cliquez sur Database actions (Actions de base de données), puis sur Database Users (Utilisateurs de base de données).
2. Localisez GGADMIN, puis cliquez sur le menu représentant des Points de suspension (trois points) et sélectionnez Modifier.
3. Dans le panneau Modifier l'utilisateur, entrez le mot du passe GGADMIN, confirmez le mot du passe, puis désélectionnez Compte verrouillé.
4. Cliquez sur Appliquer les modifications.
Chargez le schéma échantillon source et les données :
1. Dans le menu Actions de base de données, sous Développement, sélectionnez SQL.
2. Copiez le script d'OCIGGLL_OCIGGS_SETUP_USERS_ATP.sql et collez- le dans la feuille SQL Worksheet.
3. Cliquez sur Run Script (Exécuter un script). L'onglet Sortie de script affiche des messages de confirmation.
4. Effacez la feuille SQL Worksheet, puis copiez et collez le script SQL à partir de OCIGGLL_OCIGGS_SRC_USER_SEED_DATA.sql.
  
  Conseil :
  Vous devrez peut-être exécuter chaque instruction séparément pour que l'outil SQL parvienne à exécuter les scripts.
5. Pour vérifier que les tables ont bien été créées, fermez la fenêtre SQL et rouvrez-la. Dans l'onglet Navigateur, recherchez le schéma SRC_OCIGGLL, puis sélectionnez les tables de leurs listes déroulantes respectives.
Activez la journalisation supplémentaire :
1. Effacez la feuille de calcul SQL.
2. Entrez l'instruction suivante, puis cliquez sur Exécuter l'instruction :
```
ALTER PLUGGABLE DATABASE ADD SUPPLEMENTAL LOG DATA;
```

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 AI Transaction Processing source.
Créez un déploiement Big Data pour le flux d'événements Microsoft Fabric cible.
Créez une connexion au traitement des transactions Autonomous AI source.
Créez une connexion à Microsoft Fabric Eventstream.
Créez une connexion à GoldenGate, puis affectez cette connexion au déploiement Oracle source.
Affectez la connexion Autonomous AI Transaction Processing au déploiement Oracle source.
Affectez une connexion Microsoft Fabric Eventstream au déploiement Big Data cible.

Tâche 2 : ajouter l'extraction

Sur la page Déploiements, sélectionnez le déploiement Autonomous AI Transaction Processing source.
Sur la page de 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 une chaîne Extract.

Tâche 3 : ajouter un chemin de distribution

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 de la cible, sinon passez à l'étape 3.
Dans la console du déploiement ATP GoldenGate source, ajoutez une connexion de chemin pour l'utilisateur créé à l'étape 1.
1. Dans la console de déploiement ATP GoldenGate source, cliquez sur Connexions de chemin dans la navigation de gauche.
2. Cliquez sur Ajouter une connexion de chemin (icône Plus), puis effectuez les opérations suivantes :
  1. Dans Alias d'informations d'identification, entrez GGSNetwork.
  2. Dans ID utilisateur, saisissez le nom de l'utilisateur créé à l'étape 1.
  3. Indiquez le mot de passe de l'utilisateur à deux reprises pour vérification.
3. Cliquez sur Soumettre.
  
  La connexion par chemin apparaît dans la liste Connexions par chemin.
Dans la console de déploiement ATP source, ajoutez un chemin de distribution avec les valeurs suivantes :
1. Sur la page Options source :
  - Dans Extraction source, sélectionnez l'extraction créée dans la tâche 2.
  - Dans Nom de la trace, saisissez un Nom à deux caractères, tel que E1
2. Sur la page Options cible :
  - Dans Hôte cible, entrez le domaine hôte du déploiement cible.
  - Dans Numéro de port, saisissez 443.
  - Dans Nom de la trace, saisissez un Nom à deux caractères, tel que E1
  - Dans Alias, entrez l'alias d'informations d'identification créé à l'étape 2.
Dans la console de déploiement Big Data cible cible, vérifiez le Receiver Path créé consécutivements à la Distribution Path.
1. Dans la console de déploiement Big Data cible, cliquez sur Receiver Service.
2. Consultez les détails du chemin. This path was created as a result of the Distribution Path created in the previous step.

Tâche 4 : ajouter et exécuter la tâche Replicat

Dans la console de déploiement Big Data cible, cliquez sur Replicats, puis sur Add Replicat (icône Plus).
Ajoutez une réplication avec les valeurs suivantes :
1. Sur la page Informations Replicat, sous le type Replicat, sélectionnez Classic Replicat, entrez un nom de processus, puis cliquez sur Suivant.
2. Dans la page Options de réplication :
  - Dans Nom, saisissez le nom de l'élément de trace dans la tâche 2.
  - Pour Cible, sélectionnez Flux d'événements Microsoft Fabric.
  - Pour Format, sélectionnez le format à inclure dans Microsoft Fabric Eventstream. La valeur par défaut est JSON.
  - Pour Alias disponible, sélectionnez la connexion Microsoft Fabric Eventstream dans la liste déroulante.
3. Dans la page Managed Options, conservez les paramètres par défaut.
4. Sur la page Paramètres Replicat, laissez les paramètres par défaut.
5. Sur la page Propriétés Replicat, mettez à jour les champs marqués comme #TODO.
Cliquez sur Créer et exécuter.

Vous revenez à la page Réplications, où vous pouvez consulter les détails de Replicat.

Tâche 5 : vérifier la réplication

Effectuez des mises à jour de l'instance Autonomous Transaction Processing source afin que la réplication vers Microsoft Fabric Lakehouse soit effectuée.

Dans la console Oracle Cloud, ouvrez le menu De navigation, sélectionnez Oracle AI Database, puis Autonomous AI Transaction Processing.
Dans la liste des instances Autonomous AI Transaction Processing, sélectionnez votre instance source pour en visualiser les détails.
Sur la page de détails de la base de données, cliquez sur Database actions (Actions de base de données).

Remarques :
Vous devez être connecté automatiquement. Sinon, connectez-vous avec les informations d'identification de base de données.
Sur la page d'accueil des actions Database, sélectionnez SQL.

Entrez ce qui suit dans la feuille de calcul et cliquez sur Exécuter le script.

Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1000,'Houston',20,743113);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1001,'Dallas',20,822416);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1002,'San Francisco',21,157574);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1003,'Los Angeles',21,743878);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1004,'San Diego',21,840689);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1005,'Chicago',23,616472);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1006,'Memphis',23,580075);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1007,'New York City',22,124434);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1008,'Boston',22,275581);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1009,'Washington D.C.',22,688002);

In the source ATP deployment console, select the Extract name, and then click Statistics. Vérifiez que SRC_OCIGGLL.SRC_CITY comporte 10 insertions.
Dans la console de déploiement Big Data OCI GoldenGate cible, sélectionnez le nom de Replicat, puis cliquez sur Statistiques. Vérifiez que SRC_OCIGGLL.SRC_CITY comporte 10 insertions.