Configurez le paramètre Parameters lors de l'appel à ModifyDtsJobConfig pour modifier les paramètres d'une tâche DTS.
Description des paramètres
Le champ Parameters est une chaîne JSON. Spécifiez les champs suivants :
-
module
Module auquel s'applique le paramètre. Valeurs possibles :
03 : Le module Full Data Migration pour les tâches de migration ou de synchronisation de données.
04 : Le module Incremental Write pour une tâche de migration de données.
07 : Le module Incremental Write pour les tâches de synchronisation de données.
60 : Le module de synchronisation pour les tâches Kafka vers Kafka et SLS vers ClickHouse.
-
name
Nom du paramètre, tel qu'indiqué dans le tableau ci-dessous.
-
value
Valeur du paramètre, telle qu'indiquée dans le tableau ci-dessous.
|
Paramètre (name) |
Module configurable (module) |
Description (value) |
|
source.column.encoding |
03, 04 ou 07 |
Encodage des caractères des données métier dans la base de données Oracle source. Évite les problèmes d'affichage liés à l'incompatibilité des jeux de caractères. Valeurs possibles :
|
|
sink.worker.type |
03 |
Utilisez les paramètres sink.worker.type et sink.bulk.copy.enable pour configurer le mode d'écriture des données pour les bases de données MySQL ou PostgreSQL.
|
|
sink.bulk.copy.enable |
03 |
|
|
sink.batch.size.minimum |
03 |
Nombre minimal d'enregistrements écrits par lot par un thread d'écriture. Valeurs possibles : 0 à 1024. |
|
sink.batch.size.maximum |
03, 04 ou 07 |
Valeurs possibles : 0 à 1024. |
|
source.connection.idle.second |
03, 04 ou 07 |
Délai de reconnexion pour la base de données source. Si DTS se reconnecte dans ce délai, la tâche reprend automatiquement ; sinon, elle échoue. Valeurs possibles : 0 à 86 400. Unité : secondes. |
|
sink.connection.idle.second |
03, 04 ou 07 |
Délai de reconnexion pour la base de données de destination. Si DTS se reconnecte dans ce délai, la tâche reprend automatiquement ; sinon, elle échoue. Valeurs possibles : 0 à 86 400. Unité : secondes. |
|
trans.hot.merge.enable |
04 ou 07 |
Active ou désactive la fusion des points chauds (hot spot merging). Valeurs possibles :
|
|
sink.batch.enable |
4, 7 |
Active ou désactive l'écriture des données par lots. Valeurs possibles :
|
|
source.filter.ddl.enable |
04 et 07 |
Active ou désactive le filtrage des instructions DDL. Valeurs possibles :
|
|
sink.ignore.failed.ddl |
04, 07 |
Active ou désactive l'ignorance des instructions DDL ayant échoué. Valeurs possibles :
|
|
trans.size.maximum |
04, 07 |
Seuil de fragmentation des transactions. Valeurs possibles : 0 à 1024. |
|
dts.datamove.record.spouter.writers |
07 |
Nombre de threads d'écriture. Valeurs possibles : 0 à 64. |
|
selectdb.reservoir.group.by.target.schema |
04 ou 07 |
Regroupe l'écriture des données par nom de table de destination. Valeurs possibles :
|
|
selectdb.reservoir.timeout.milliseconds |
04 ou 07 |
Délai d'expiration pour le regroupement des écritures, en millisecondes.
|
|
sink.task.number |
03, 04, 07 ou 60 |
Nombre de threads d'écriture pour la base de données de destination. Une valeur plus élevée améliore les performances d'écriture dans les scénarios sans points chauds, mais augmente la charge de la base de données.
|
Exemple
Exemple au format JSON :
[
{
"module": "07",
"name": "sink.connection.idle.second",
"value": 60
},
{
"module": "07",
"name": "sink.batch.size.maximum",
"value": 64
}
]