Snowflake Insert Documentation

Version: 3.0.1

Retrieved: 2025-10-09 15:16:21

Snowflake Insert

This module inserts flow message data into Snowflake database row(s).

Settings

Credential

This module needs a credential of type 'Connection string' to connect to the database server. Use the following format.

account=xyz.north-europe.azure;user=crosser;password=password;warehouse=warehouse1

The warehouse parameter is optional, but if it's not set a default warehouse have to be set for the user.

To use a connection string with a certificate private key, use the 'Connection string with cert' instead, when using this there is no need to set 'private_key_pwd', 'private_key_file', 'password', 'authenticator' or 'private_key' in the connection string.

The connection string can in this case look like this:

account=xyz.north-europe.azure;user=crosser;

To get your Snowflake account, go to your organization information in the bottom left corner and click on the link symbol. Copy this information and remove the first part (https://) and also the last part (snowflakecomputing.com).

Note: When using JWT authentication (certificate-based), connection pooling is automatically disabled to prevent issues with token expiration. The module will automatically append poolingEnabled=false to the connection string if not already specified.

NOTE: if the node is running behind a proxy, the following values needs to be added to the connection string USEPROXY=true PROXYHOST=abc.xyz.com PROXYPORT=8080

if the proxy server needs authentication, the additional info is also needed PROXYUSER=username PROXYPASSWORD=pw

Input

For a single row insert the Source Property is expected to contain an object with property names matching all required column names in the database table. For multi-row inserts the Source Property is expected to contain an array of single-row objects.

Output

An output message will be sent each time the module receives a message.

Examples

Example 1

Inserts a single row into the table test. The table expects at least two columns name and reading:

# Settings

Source Property: info.data

Table Name: test

# Input

{
  "id": 1
    "name": "machine",
    "info": {
        "data": {
            "name": "sensor1",
            "reading": 489
        }
    }
 }

Example 2

Inserts multiple rows into the table test. The table expects at least two columns name and reading:

# Settings

Source Property: info.data

Table Name: test

# Input

{
  "id": 1
    "name": "machine",
    "info": {
        "data": [
            {
                "name": "sensor1",
                "reading": 489
            },
            {
                "name": "sensor2",
                "reading": 375
            },
            {
                "name": "sensor3",
                "reading": 961
            }
        ]
    }
 }