Transmettre un argument d'exécution à un job de réplication

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

Transmettre un argument Debezium à une tâche 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 pour le job 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 le paramètre de réplication en lui ajoutant le préfixe 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 Microservices de préférences CDAP référence.

Configurer les paramètres JDBC

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

Par exemple, pour configurer le paramètre JDBC sessionVariables sur MAX_EXECUTION_TIME=43200000, définir 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 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 ne permet pas de définir des arguments JDBC pendant le la configuration ou l'évaluation d'un job de réplication. Si vous devez configurer JDBC pour résoudre les problèmes d'évaluation, contourner l'évaluation en déployant le job de réplication via API Replication : Ensuite, avant de démarrer le job, configurez les arguments JDBC comme décrit plus tôt dans cette section.

Configurer le paramètre de clé primaire

La table source répliquée doit posséder une clé primaire. Cette exigence stricte ne s'applique que lorsque la base de données source est Oracle. Pour SQL Server et sources MySQL, vous pouvez spécifier une clé primaire personnalisée, même si la source n'en comporte 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. La 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 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.