Transmettre un argument d'environnement d'exécution à une tâche de réplication

Cette page explique comment transmettre des arguments d'exécution dans les tâches de réplication Cloud Data Fusion.

Transmettre un argument Debezium à un job de réplication

Pour transmettre un argument d'une application Debezium à une tâche de réplication MySQL ou SQL Server dans Cloud Data Fusion, spécifiez un argument d'exécution à l'aide du préfixe source.connector.

Console

1. Accédez à votre instance :

   1. Dans la console Google Cloud, accédez à la page Cloud Data Fusion.

   2. Pour ouvrir l'instance dans Cloud Data Fusion Studio, cliquez sur Instances, puis sur Afficher l'instance.

      Accéder à la page "Instances"

2. Cliquez sur  Menu > Centre de contrôle.

3. Recherchez l'application de la tâche de réplication, puis cliquez sur Préférences. La fenêtre Préférences s'ouvre.

4. Dans le champ Clé, spécifiez un argument d'exécution pour la tâche de réplication en le préfixant par source.connector.

   

5. Cliquez sur Enregistrer et fermer.

API REST

Pour définir un argument d'exécution à l'aide de l'API REST, consultez la documentation de référence sur les microservices de préférences CDAP.

Configurer les paramètres JDBC

Pour transmettre un paramètre JDBC à une tâche de réplication MySQL ou SQL Server, spécifiez l'argument d'exécution précédé du préfixe source.connector.database.

Par exemple, pour configurer le paramètre JDBC sessionVariables sur MAX_EXECUTION_TIME=43200000, définissez un argument d'exécution avec la clé source.connector.database.sessionVariables et la valeur MAX_EXECUTION_TIME=43200000.

Pour configurer plusieurs paramètres JDBC, définissez un argument d'exécution pour chaque paramètre. Par exemple, pour configurer les paramètres JDBC encrypt=true&trustServerCertificate=true, transmettez les arguments suivants:

Clé	Valeur
source.connector.database.encrypt	true
source.connector.database.trustServerCertificate	true

Remarque :Cloud Data Fusion n'est pas compatible avec la définition d'arguments JDBC lors de la configuration ou de l'évaluation d'une tâche de réplication. Si vous devez définir des paramètres JDBC pour résoudre des problèmes d'évaluation, contournez l'évaluation en déployant la tâche de réplication via l'API de réplication. Ensuite, avant de démarrer la tâche, configurez les arguments JDBC comme décrit précédemment dans cette section.

Configurer le paramètre de clé primaire

La table source répliquée doit disposer d'une clé primaire. Cette exigence stricte ne s'applique que lorsque la base de données source est Oracle. Pour les sources SQL Server et MySQL, vous pouvez spécifier une clé primaire personnalisée, même si la table source n'en a pas.

Définissez le paramètre key avec l'argument d'exécution suivant:

source.connector.message.key.columns = SCHEMA.TABLE:KEY_COLUMN

Remplacez les éléments suivants :

• SCHEMA: nom du schéma source.
• TABLE: nom de la table source.
• KEY_COLUMN: colonne contenant la clé sécurisée.

Vous pouvez définir la clé primaire de plusieurs tables avec la propriété key. L'exemple suivant montre comment définir la clé pour les tables inventory.customers et purchase.orders:

source.connector.message.key.columns = inventory.customers:pk1,pk2;purchase.orders:pk3,pk4

Configurer le mode d'isolation pour un instantané dans la réplication SQL Server

Pour en savoir plus sur l'argument d'exécution pour le mode d'isolation, consultez la section Niveaux d'isolation dans la réplication SQL Server.

Étape suivante

• En savoir plus sur la réplication dans Cloud Data Fusion.
• Consultez la documentation de référence de l'API Replication.