Openflow Connector for PostgreSQL : Configurer la réplication incrémentielle sans instantanés

Note

Ce connecteur est soumis aux conditions d’utilisation de Snowflake Connector.

Le connecteur Openflow Connector for PostgreSQL peut être configuré pour démarrer immédiatement la réplication des modifications incrémentielles pour les tables nouvellement ajoutées, en contournant les instantanés. Le chargement incrémentiel est utile lorsque vous réinstallez le connecteur sur des données précédemment répliquées et pour poursuivre la réplication sans avoir à créer à nouveau un instantané de chaque table.

La réplication incrémentielle peut être activée dans une nouvelle instance du connecteur, ou dans une instance existante.

Pour activer la réplication incrémentielle dans une nouvelle instance du connecteur, effectuez les tâches suivantes :

  1. Démarrez le connecteur comme décrit dans Paramétrez Openflow Connector for PostgreSQL.

  2. Dans le contexte PostgreSQL Ingestion Parameters, définissez le paramètre Ingestion Type sur incremental.

Activer la réplication incrémentielle sans instantanés

Pour activer la réplication incrémentielle sur un connecteur existant, procédez comme suit :

  1. Sign in to Snowsight.

  2. In the navigation menu, select Ingestion » Openflow.

  3. Dans le volet Openflow, sélectionnez l’onglet Runtimes.

  4. Sélectionnez l’environnement d’exécution contenant le connecteur.

  5. Sélectionnez le connecteur.

  6. Dans le contexte Ingestion Parameters, spécifiez Ingestion Type = incremental.

  7. Ajoutez de nouvelles tables de réplication. Ces tables passent immédiatement à leur chargement incrémentiel.

Note

Pour revenir à la réplication des tables avec le chargement de l’instantané, modifiez Ingestion Type de incremental à full.

Notes sur l’utilisation

  • Modifier la valeur de Ingestion Type n’a pas d’impact sur les tables qui ont commencé à répliquer des données. Les tables actuellement en phase d’instantané continuent jusqu’à ce que le chargement de l’instantané soit terminé.

  • Alors que Ingestion Type est défini sur incremental, les nouvelles tables ajoutées à la liste des tables répliquées contournent la phase d’instantané. Cela inclut les nouvelles tables ajoutées à la base de données source qui correspondent au paramètre Included Table Regex. Assurez-vous que le type d’ingestion est défini sur incremental pour contourner la phase d’instantané.

    Note

    Les connecteurs ne doivent rester en mode incremental que tant que cela est nécessaire, car ce mode contourne les instantanés. Une fois que les besoins du client en matière de mises à jour incrémentielles ont été satisfaits, le connecteur doit revenir au mode full.

  • Pour les tables qui contournent le chargement d’instantanés, le connecteur crée une table de destination dans Snowflake, en exécutant CREATE TABLE IF NOT EXISTS, uniquement si aucune table de destination n’existe déjà. Les tables qui passent par l’instantané nécessitent qu’aucune table de destination n’existe.