Ajouter un processus d'extraction pour MongoDB

L'extraction est un processus qui s'exécute sur la connexion à la source de données sources et extrait ou saisit des données. Voyez comment ajouter un processus d'extraction pour MongoDB.

Ajouter un extrait (26ai)

Avant de commencer, vérifiez que vous :
  • Vérifiez les détails propres à ce type de connexion source.
  • Configurez un jeu de réplications MongoDB :
    • OCI GoldenGate pour le service de mégadonnées utilise le journal des opérations (oplog) pour lire les enregistrements de saisie de modification de données (CDC). L'oplog est une collection plafonnée dans MongoDB qui tient à jour un enregistrement continu de toutes les opérations qui modifient la base de données. Les fichiers Oplog sont créés lorsqu'un jeu de répliques est activé dans MongoDB.
    • MongoDB Atlas est préconfiguré avec un jeu de réplication. Pour les déploiements MongoDB sur place, vous devez configurer et déployer manuellement un jeu de réplication pour activer la fonctionnalité oplog et CDC. Pour MongoDB sur place, vous devez déployer un jeu de répliques.
  • Avoir MongoDB version 3.6 ou ultérieure.
  • Avoir la prise en charge d'OCI GoldenGate pour saisir les opérations suivantes : INSERT, UPDATE, DELETE.
Pour ajouter une extraction dans pour MongoDB :
  1. Dans le menu de navigation de la console de déploiement d'OCI GoldenGate, cliquez sur Extractions.
  2. Dans le panneau Ajouter une extraction, dans la page Extraire des informations, remplissez les champs suivants selon les besoins, puis cliquez sur Suivant :
    • Entrez un nom de processus de 8 caractères au maximum.
    • Entrez une description (facultatif) pour vous aider à distinguer ce processus des autres.
    • Sélectionnez une source dans la liste déroulante.
  3. Dans la page Options d'extraction, remplissez les champs suivants, au besoin, puis cliquez sur Suivant :
    1. Pour Extraire la piste :
      1. Entrez un nom pour le processus d'extraction.
      2. Entrez un nom de sous-répertoire pour définir un emplacement personnalisé pour le fichier de piste généré.
      3. Entrez Séquence de piste pour définir le numéro de départ des fichiers de piste.
      4. Entrez une taille de la piste pour définir la taille maximale du fichier de piste généré.
      5. Sélectionnez un profil de chiffrement. Le profil de portefeuille local est sélectionné par défaut si aucun profil de chiffrement n'a été créé.
      6. Sélectionnez un algorithme de chiffrement :
        • NONE
        • AES256
        • AES192
        • AES128
    2. Pour Données d'identification sources, sélectionnez les éléments suivants :
      1. Domaine
      2. Alias
      3. Quand et où début
  4. Dans la page Options gérées, remplissez les champs facultatifs suivants, au besoin, puis cliquez sur Suivant :
    • Nom du profil
    • Critique pour l'état du déploiement
    • Démarrage automatique
    • Redémarrage automatique

    Note :

    L'ajout d'un profil et la configuration des options de démarrage automatique et de redémarrage automatique permettent à votre déploiement de redémarrer automatiquement après une interruption du réseau. Voir Configurer les processus gérés pour en savoir plus.

  5. Dans la page Fichier de paramètres, mettez à jour le mappage source avec TABLE source.*;

    Note :

    Il s'agit du mappage base de données/collecte source. TABLE *.*; entraîne l'extraction du processus à partir de toutes les bases de données/collections.
  6. Cliquez sur Créer et exécuter pour créer et démarrer l'extraction. Si vous cliquez sur Créer, vous pouvez démarrer manuellement l'extraction plus tard à partir de la page Extractions.

Ajouter un processus d'extraction (21c)

Voyez comment ajouter un processus d'extraction pour une source MongoDB dans OCI GoldenGate

Pour ajouter une extraction pour MongoDB :
  1. Dans la console de déploiement d'OCI GoldenGate, assurez-vous d'être dans la page Aperçu du service d'administration, puis cliquez sur Ajouter une extraction (icône plus).
  2. Dans la page Ajouter une extraction, pour le type d'extraction sélectionnez l'une des options suivantes, puis cliquez sur Suivant :
    • Chargement initial
    • Saisie de modification de données
  3. Dans la page Options d'extraction, entrez les valeurs suivantes dans les champs, puis cliquez sur Suivant :
    1. Pour Nom du processus, entrez un nom pour le processus d'extraction.
    2. Pour Alias de connexion, sélectionnez l'alias de connexion dans la liste déroulante.
    3. Pour Source, sélectionnez Fichier.
    4. Pour Nom de fichier, entrez trois caractères au minimum pour le nom de fichier.
    5. (Facultatif) Sous Options gérées, vous pouvez configurer les éléments suivants :
      • Nom du profil
      • Démarrage automatique
      • Redémarrage automatique

      Note :

      L'ajout d'un profil et la configuration des options de démarrage automatique et de redémarrage automatique permettent à votre déploiement de redémarrer automatiquement après une interruption du réseau. Pour plus d'informations, voir Configurer les processus gérés.
  4. Dans la page Fichier de paramètres, mettez à jour le mappage source avec TABLE source.*;

    Note :

    Il s'agit du mappage base de données/collecte source. TABLE *.*; entraîne l'extraction du processus à partir de toutes les bases de données/collections.
  5. Cliquez sur Créer et exécuter.
Vous revenez à la page Overview du service d'administration. Cliquez sur le nom de l'extraction pour voir les détails et les rapports de l'extraction.

Problèmes connus

Échec de Replicats lors de l'utilisation de Trail file à partir de MongoDB Extract avec BINARY_JSON_FORMAT

Lorsqu'un élément Replicat utilise un élément Trail file généré à partir d'un élément Extract MongoDB avec BINARY_JSON_FORMAT dans le fichier de paramètres Extract, Replicat échoue avec l'erreur suivante :

ERROR 2023-08-04 17:13:13.000421 [main] - Unable to decode column 0 : Input length = 1
      java.nio.charset.MalformedInputException: Input length = 1 at
      java.nio.charset.CoderResult.throwException(CoderResult.java:281) ~[?:1.8.0_311]at java.nio.charset.CharsetDecoder.decode(CharsetDecoder.java:816) ~[?:1.8.0_311] at
      oracle.goldengate.datasource.UserExitDataSource.createColumnValue(UserExitDataSource.java:1106)
      [ggdbutil-21.9.0.0.3.001.jar:21.9.0.0.3.001] Exception in thread “main”
      oracle.goldengate.util.GGException: Unable to decode column 0 : Input length = 1 at
      oracle.goldengate.datasource.UserExitDataSource.createColumnValue(UserExitDataSource.java:1203)

Solution de rechange : Lorsque BINARY_JSON_FORMAT est supprimé des paramètres Extract, Replicat s'exécute avec succès et les documents sont représentés au format JSON étendu.