Skip to main content

Create a Snowflake Reader application using TQL

CREATE OR REPLACE APPLICATION demo_app1;

CREATE OR REPLACE SOURCE src USING Global.SnowflakeReader ( 
  adapterName: 'SnowflakeReader', 
  connectionProfileName: 'admin.snowflakekeypair', 
  tables: 'PUBLIC.%', 
  excludedTables: 'PUBLIC.SAMPLETABLE1', 
  pollingInterval: '60s', 
  startTimestamp: 'PUBLIC.SAMPLETABLE2:\'2023-09-28T03:02:56.287-07:00\';
    PUBLIC.SAMPLETABLE5:\'2023-09-29t04:15:26.539-07:00\'', 
  connectionRetryPolicy: 'initialRetryDelay=10, retryDelayMultiplier=1.0, maxRetryDelay=30,
    maxAttempts=3, totalTimeout=600', 
  SnowflakeConfiguration: 'ThreadPoolSize=1',
  CDDLCapture: 'true',
  CDDLAction: 'Process' ) 
OUTPUT TO s1;

CREATE TARGET tgt USING Global.SysOut ( 
  name: 'tgt' ) 
INPUT FROM s1;

END APPLICATION demo_app1;