This example Data Stream demonstrates how to use the Listener to return data readings from a Snowflake database table.

Refer to configuration to understand all configuration options of this Agent.

Step 1: Add the Agent

Drag the Snowflake Listener onto the canvas and rename it. Link the output endpoint to the printer and save the Data Stream.

Step 2: Configure General

Select the Agent and click Configure. In this case, keep the default Collection and polling interval.

Step 3: Configure Server

Enter the authentication details of the Snowflake account to which you want to connect: organization, account, username, and password.

Step 4: Configure Database

Select the database.

Optionally, select a Schema, which will filter the options displayed in the Table dropdown.

Select the table.

Select which columns should be returned.

Step 5: Configure Timestamp

Select the column that is used to determine which rows are new since the last poll.

Step 6: Results

Apply the changes and save the Data Stream.

Publish it and let's look at the Live Data View. Observe that new rows are printed every 10 seconds - these are the rows that were added to the Snowflake table since the last poll.


See the Import, Export, and Clone - XMPro article for steps to import a Data Stream.

Last updated