Creating a Job for writing and reading Snowflake data - 7.0

Snowflake

author
Talend Documentation Team
EnrichVersion
7.0
EnrichProdName
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 Open Studio for MDM
Talend Real-Time Big Data Platform
task
Data Governance > Third-party systems > Cloud storages > Snowflake components
Data Quality and Preparation > Third-party systems > Cloud storages > Snowflake components
Design and Development > Third-party systems > Cloud storages > Snowflake components
EnrichPlatform
Talend Studio
Create a Job to connect to Snowflake, create a Snowflake table, write data into the table and then read data from the table, finally close the connection to Snowflake.

Before you begin

  • The Snowflake data warehouse to be used is started but not in the Suspended status.

  • The Snowflake role assigned to you has read and write permissions to the database to be connected.

If you are not sure about these requirements, ask the administrator of your Snowflake system.

Procedure

  1. In the Integration perspective of the Studio, create a new Job from the Job Designs node in the Repository tree view.
  2. Add a tSnowflakeConnection component, a tSnowflakeRow component, a tFixedFlowInput component, a tSnowflakeOutput component, a tSnowflakeInput component, a tLogRow component, and a tSnowflakeClose component to the Job.
  3. Connect the tFixedFlowInput component to the tSnowflakeOutput component using a Row > Main connection.
  4. Do the same to connect the tSnowflakeInput component to the tLogRow component.
  5. Connect the tSnowflakeConnection component to the tSnowflakeRow component using a Trigger > On Subjob Ok connection.
  6. Do the same to connect the tSnowflakeRow component to the tFixedFlowInput component, the tFixedFlowInput component to the tSnowflakeInput component, and the tSnowflakeInput component to the tSnowflakeClose component.