tPostgresqlCDC
Ce composant répond aux besoins en extraction et transport de données. Il extrait uniquement les changements apportés aux données source et les met à disposition de(s) système(s) cible(s) utilisant l'aperçu de base de données CDC.
Le tPostgresqlCDC extrait les données de système source modifiées depuis de la dernière extraction et les transfère vers un ou plusieurs autre(s) système(s).
Propriétés du tPostgresqlCDC Standard
Ces propriétés sont utilisées pour configurer le tPostgresqlCDC s'exécutant dans le framework de Jobs Standard.
Le composant tPostgresqlCDC Standard appartient à la famille Bases de données.
Le composant de ce framework est disponible dans tous les produits Talend nécessitant une souscription.
Basic settings
| Propriétés | Description |
|---|---|
| Base de données |
Sélectionnez le type de base de données dans la liste et cliquez sur Apply (Appliquer). |
|
Property type |
|
|
Use an existing connection |
Cochez cette case et sélectionnez le composant de connexion adéquat dans la liste Component list pour réutiliser les paramètres d'une connexion que vous avez déjà définie. Note InformationsRemarque : Lorsqu'un Job contient un Job parent et un Job enfant, si vous devez partager une connexion existante entre ces deux niveaux, par exemple pour partager la connexion créée par le Job parent au Job enfant, procédez comme suit.
Pour un exemple de partage d'une connexion à une base de données à travers différents niveaux de Jobs, consultez Partager une connexion à une base de données. |
|
DB Version |
Liste des versions de la base de données. |
|
Host |
Adresse IP du serveur de base de données. |
|
Port |
Numéro du port d'écoute du serveur de base de données. |
|
Database |
Saisissez le nom de la base de données. |
|
Schema |
Nom exact du schéma. |
|
Username et Password |
Données d'authentification de l’utilisateur ou l'utilisatrice de la base de données. Pour saisir le mot de passe, cliquez sur le bouton [...] à côté du champ Password, puis, dans la boîte de dialogue qui s'ouvre, saisissez le mot de passe entre guillemets doubles et cliquez sur OK afin de sauvegarder les paramètres. |
|
Schema using CDC et Edit Schema |
|
|
Table |
Nom de la table source dans laquelle capturer les changements apportés aux données. |
|
Subscriber |
Saisissez le nom du souscripteur ayant accès à la table de modifications. |
|
Events to catch |
Insert : cochez cette case pour capturer les données insérées dans la table de modifications depuis la dernière extraction. Update : cochez cette case pour capturer les données mises à jour dans la table de modifications depuis la dernière extraction. Delete : cochez cette case pour capturer les données supprimées dans la table de modifications depuis la dernière extraction. |
Advanced settings
| Propriétés | Description |
|---|---|
| Additional JDBC Parameters | Spécifiez des paramètres JDBC supplémentaires pour la connexion à la base de données créée. Cette propriété est indisponible lorsque la case Use an existing connection de la vue Basic settings est cochée. |
| Conserver les données dans la table CDC | Cochez cette case pour conserver les modifications dans la table CDC, ce qui permet à un système cible ou plusieurs de consulter les données même après ingestion. Lorsque cette option est activée, elle empêche la suppression des données CDC consultées ; à la place elle met à jour la valeur du champ CDC_STATE à 'x'. Ce mécanisme permet aux utilisateur·trices de vérifier à nouveau les données ingérées en filtrant les enregistrements où CDC_STATE = 'x' (par exemple, avec un tMysqlInput) et de gérer eux-mêmes ou elles-mêmes les suppressions au besoin. Cette option est particulièrement utile pour les utilisateur·trices devant auditer ou revisiter des données ingérées sans avoir à réexécuter les Jobs ou effectuer de processus de rétro-ingénierie pour comprendre comment la case affecte CDC_STATE. |
| Use cursor | Cochez cette case et définissez le nombre de lignes avec lesquelles vous souhaitez travailler en une fois. Cette option permet d'optimiser les performances. |
| Trim all the String/Char columns | Cochez cette case pour supprimer les espaces en début et en fin de champ dans toutes les colonnes contenant des chaînes de caractères. |
| Trim columns | Supprimez les espaces blancs en début et fin de champ dans les colonnes sélectionnées. Note InformationsRemarque : Décochez la case Trim all the String/Char columns pour activer ce champ.
|
| tStatCatcher Statistics | Cochez cette case afin de collecter les informations de log au niveau du composant. |
| Enable parallel execution |
Cocher cette case permet de traiter plusieurs flux de données simultanément. Notez que cette fonctionnalité dépend de la capacité de la base de données ou de l'application à gérer plusieurs insertions en parallèle ainsi que le nombre de processeurs utilisés. Dans le champ Number of parallel executions, vous pouvez :
Notez que lorsque l'exécution parallèle est activée, il n'est pas possible d'utiliser les variables globales pour retrouver les valeurs de retour dans un sous-Job.
|
Variables globales
| Variables | Description |
|---|---|
| Variables globales |
NB_LINE : nombre de lignes lues par un composant d'entrée ou passées à un composant de sortie. Cette variable est une variable After et retourne un entier. Pour renseigner un champ ou une expression à l'aide d'une variable, appuyez sur les touches Ctrl+Espace pour accéder à la liste des variables. À partir de cette liste, vous pouvez choisir la variable que vous souhaitez utiliser. Pour plus d'informations concernant les variables, consultez Utiliser les contextes et les variables. Une variable Flow fonctionne durant l'exécution d'un composant. Une variable After fonctionne après l'exécution d'un composant. |
Utilisation
| Conseils d'utilisation | Description |
|---|---|
| Règle d'utilisation | Ce composant est généralement utilisé comme composant de début. Il nécessite un composant de sortie et une connexion de type Row Main. |