Snowflake Streaming Connector Setup Guide

API Information

This connector uses the following vendor SDK:

• Snowflake Ingest SDK Version: 3.0.1

Actions

Action name	AudienceStream	EventStream
Send Custom Event Data	✗	✓
Send Entire Event Data	✗	✓
Send Custom Visitor Data	✓	✗
Send Entire Visitor Data	✓	✗

How it works

The Snowflake Streaming connector leverages the powerful Snowflake Snowpipe Streaming feature to enable near real-time importing of event and visitor data directly into Snowflake staging tables, enabling immediate availability for processing and analytics with data latency under 10 seconds. Send either the entire dataset or specific attributes to the staging table, ensuring customizable data integration tailored to business needs.

Using Snowpipe Streaming creates a streamlined pathway to enhance data accessibility and analytical capabilities within Snowflake while decreasing latency and costs. By removing third party integrations and using the Snowpipe Streaming serverless compute model, the Snowflake Streaming connector provides a cost effective, secure connection.

The Snowflake Streaming connector enables you to unlock a number of use cases, including:

• Identity: Populate and activate identity graphs using cleansed, normalized, real-time identity data.
• Insights: Improve and activate differentiated intelligence with rich, high quality, integrated data.
• AI: Inform and activate AI initiatives with a real-time data layer.
• Consent: Ensure insights and activation always respect customer privacy and preferences.

Staging tables

The staging table in Snowflake that is intended to received data from Tealium must contain specific columns depending on the selected connector action.

When using either Send Entire Event Data or Send Entire Visitor Data actions, the staging table must have a VARIANT column to receive the dataset and a column to receive the timestamp. The timestamp column must support the timestamp data format that is sent.

When using either Send Custom Event Data or Send Custom Visitor Data, the staging table must have a column for each data type. Each data attribute must be assigned to a column. Ensure that each attribute is an accepted Snowflake data type and that the column is formatted properly to receive this data type. To map a timestamp, a separate timestamp column must be added.

For more information, see Snowflake: Supported Java data types.

Data types

The following table summarizes the data types supported by the Snowflake Streaming connector:

Snowflake Data Type	Supported
Numeric data types	✓
String and binary data types	✓
Logical data types	✓
Date and time data types	✓
Arrays	✓
Object	✓
Variant	✓
Vector	✗
Geography	✗
Geometry	✗

Table and column configurations

The connector does not support the following table or column configurations:

• Columns with collations
• TRANSIENT or TEMPORARY tables
• Tables with AUTOINCREMENT or IDENTITY column settings
• A default column value that is not NULL

IP addresses to allow

Snowflake has strict rules about which systems it accepts requests from. You will need to add the Tealium IP addresses to your Snowflake allow list.

You must add the us-west-1 and the server-side profile region addresses to your allowlist. If you do not add these addresses to your allowlist, you will see errors when you try to fetch data. Tealium uses the us-west-1 IP addresses during connector configuration.

Best practices

We recommend the following Snowflake table configurations for the Snowflake Streaming connector:

• 1 event feed per table
• 1 audience per table

Concurrent writing of tables by more than one feed or audience may result in performance errors.

Configuration

Navigate to the Connector Marketplace and add a new connector. For general instructions on how to add a connector, see About Connectors.

After adding the connector, configure the following settings:

• Username
  The Snowflake account username. Must either have OWNERSHIP or INSERT rights to the Snowflake table that is receiving the data.

• Role
  Access control role to use for the session.

• URL
  The Snowflake account URL in the following format: <account_identifier>.snowflakecomputing.com

• Private Key
  The customer-generated private key. Supports both encrypted and unencrypted private keys. For instructions on generating the Snowflake private key, see Snowflake: Key-pair authentication and key-pair rotation.

  If the private key is encrypted, you must provide the Private Key Passphrase.

• Private Key Passphrase
  The encrypted private key passphrase for use with an encrypted private key. Do not assign a value if the private key is unencrypted.

To complete the connector authentication, use the following steps to alter the above user with public key details in Snowflake:

1. Generate a public key in Snowflake. For information, see Generate a Public Key.
2. Assign the public key to the above user by using an ALTER USER command in Snowflake. Only owners of users or users with SECURITYADMIN roles or higher can alter a user. For more information, see Assign the public key to a Snowflake user.
   To successfully assign the public key to the user, ensure the following:
   • Enter the Snowflake username in double quotes ("). For example, "SNOWFLAKE.USER".
   • Copy and paste the public key without line breaks.
3. Run the query to update the user with the new public key.

Snowflake supports public and private key rotations. For more information, see Configuring key-pair rotation.

Actions

The following section lists the supported parameters for each action.

Send Custom Event Data

Parameters

Parameter	Description
Database Name	The Snowflake database that contains the required table.
Schema Name	The name of the schema used in the table.
Table Name	The name of the table you want to insert data into.
Event Parameters	Map the event parameters to the columns in the Snowflake table.

Send Entire Event Data

Parameters

Parameter	Description
Database Name	The Snowflake database that contains the required table.
Schema Name	The name of the schema used in the table.
Table Name	The name of the table you want to insert data into.
Column to record the payload	Choose the VARIANT column to record the event data.
Timestamp	Select the column to send the timestamp variable to.
Timestamp Attribute	(Optional) The default sends the current timestamp for the action. Select an attribute to assign as the timestamp if you want to send a different format. For more information, see Snowflake: Supported Java data types. If an attribute is assigned and produces an empty value, we will send the current timestamp.

Send Custom Visitor Data

Parameters

Parameter	Description
Database Name	The Snowflake database that contains the required table.
Schema Name	The name of the schema used in the table.
Table Name	The name of the table you want to insert data into.
Visitor Parameters	Map the visitor parameters to the columns in the Snowflake table.

Send Entire Visitor Data

Parameters

Parameter	Description
Database Name	The Snowflake database that contains the required table.
Schema Name	The name of the schema used in the table.
Table Name	The name of the table you want to insert data into.
Column to record the visitor data	Choose the VARIANT column to record the visitor data.
Include Current Visit Data	Selecting this option will include both visitor data and current visit data in the data sent to Snowflake.
Timestamp	Select the column to send the timestamp variable to.
Timestamp Attribute	(Optional) The default sends the current timestamp for the action. Select an attribute to assign as the timestamp if you want to send a different format. For more information, see Snowflake: Supported Java data types. If an attribute is assigned and produces an empty value, we will send the current timestamp.

Drop channels

To drop channels that Tealium has created, provide a list of channels in CSV format. You can retrieve the list of channels by running SHOW CHANNELS in your Snowflake instance. To drop all channels created by Tealium, leave the list blank.

To configure channels to drop, use the following steps:

1. Go to Server-Side > EventStream > Event Connectors or to Server-Side > AudienceStream > Audience Connectors.
2. Select a Snowflake connector.
3. Under Remote Configuration, click Drop Channel.
4. Enter the following information:
   • Database Name
     Required. The Snowflake data base name for the table.
   • Schema Name
     Required. The name of the schema used in the table.
   • Table Name
     Required. The name of the Snowflake table.
   • Channel Name
     The names of the Snowflake channels to drop, in CSV format. If no channel name is provided, all channels are dropped.
5. Click Drop.

If your list of tables is large and the deletion takes longer than 30 seconds, a false error stating that channels were not deleted may occur. We recommend that you validate that channels were successfully deleted by running SHOW CHANNELS in your Snowflake instance.