Écrire des données dans Snowflake - 7.3

Snowflake

Version
7.3
Language
Français
Product
Talend Big Data
Talend Big Data Platform
Talend Data Fabric
Talend Data Integration
Talend Data Management Platform
Talend Data Services Platform
Talend ESB
Talend MDM Platform
Talend Open Studio for Big Data
Talend Open Studio for Data Integration
Talend Open Studio for ESB
Talend Real-Time Big Data Platform
Module
Studio Talend
Content
Création et développement > Systèmes tiers > Stockages Cloud > Composants Snowflake
Gouvernance de données > Systèmes tiers > Stockages Cloud > Composants Snowflake
Qualité et préparation de données > Systèmes tiers > Stockages Cloud > Composants Snowflake
Configurez le composant tFixedFlowInput et le tSnowflakeOutput pour écrire des données dans Snowflake.

Procédure

  1. Double-cliquez sur le tFixedFlowInput pour ouvrir sa vue Basic settings.
  2. Cliquez sur le bouton [...] à côté du champ Edit schema et, dans la fenêtre de schéma qui s'ouvre, définissez le schéma en ajoutant quatre colonnes, ID de type int, NAME et SALARY de type String et ONBOARD de type Date.
  3. Cliquez sur OK pour valider ces modifications et acceptez la propagation proposée par la boîte de dialogue qui s'ouvre.
  4. Dans le champ Number of rows, saisissez le nombre d'enregistrements à générer, 5 dans cet exemple.
  5. Dans la zone Mode, sélectionnez Use Single Table et spécifiez la valeur pour chaque colonne.
    • ID : numéro automatiquement incrémenté par la routine Numeric.sequence("id",1,1).

    • NAME : prénom aléatoire généré par la routine TalendDataGenerator.getFirstName().

    • ONBOARD : date aléatoire générée par la routine TalendDate.getRandomDate("2007-09-01",";2017-09-01").

    • SALARY : données semi-structurées JSON au format {"Salary": value}, où la valeur du salaire est générée par la routine Numeric.random(100000,200000).

  6. Double-cliquez sur le composant tSnowflakeOutput pour ouvrir sa vue Basic settings.
  7. Dans la liste déroulante Connection Component, sélectionnez le composant tSnowflakeConnection pour réutiliser la connexion créée par ce composant.
  8. Cliquez sur le bouton [...] à côté du champ Table et, dans la boîte de dialogue qui s'ouvre, cochez la case Use custom object et saisissez dans le champ Object Name le nom de la table dans laquelle écrire les données. Dans cet exemple, saisissez EMPLOYEE, la table créée par le composant tSnowflakeRow. Cela fait, cliquez sur OK pour fermer la boîte de dialogue.
  9. Dans la liste Output action, sélectionnez Insert pour écrire les données dans la table EMPLOYEE.