In this article
...
You can use this Snap to insert data into Snowflake using the Snowpipe Streaming API, which enables the continuous ingestion of data into Snowflake tables as and when it is available.
The Snowpipe Streaming Snap uses the role defined in the accounts' Url properties field. If a role is not defined, the Snap runs a SELECT CURRENT_ROLE()
to determine a suitable role, failing which it falls back to the PUBLIC role.
...
Snap Type
The Snowflake – Snowpipe Streaming Snap is a Write-type Snap.
Prerequisites
Valid client IDSnowflake KeyPair or OAuth 2.0 account.
A valid account with the required permissions.
...
Limitations and Known Issues
None.
Snap Views
Type | Format | Number of Views | Examples of Upstream and Downstream Snaps | Description |
---|---|---|---|---|
Input | Document
|
|
| Requires the table name where the data has to be inserted and the data flush interval (milliseconds) in which the data is pushed to the database. |
Output | Document
|
|
| Inserts data in Snowflake tables in specified intervals. |
Error | Error handling is a generic way to handle errors without losing data or failing the Snap execution. You can handle the errors that the Snap might encounter when running the pipeline by choosing one of the following options from the When errors occur list under the Views tab:
Learn more about Error handling in Pipelines. |
Snap Settings
Info |
---|
|
Field Name | Field Type | Description |
---|---|---|
Label*
Default Value: Snowflake – Snowpipe Streaming | String | Specify the name for the Snap. You can modify this to be more specific, especially if you have more than one of the same Snap in your pipeline.
|
Schema name
Default Value: N/A | String/Expression/Suggestion | Specify the database schema name. |
Table Name*
Default Value: N/A | String/Expression/Suggestion | Specify the table name on which the insert operation has to be executed. |
Create table if not present
Default Value: Deselected | Checkbox | Select this checkbox if you want the table to be automatically created if it does not already exist. |
Max client lag*
Default Value: 1000 | Integer/Expression/Suggestion | Specify the client data flush interval in milliseconds. Adjust this value based on the maximum latency your target system can handle (60,000 ms). This field also accepts inputs in n-second and n-minute formats. Maximum value is 10 minutes. |
Snap execution Default Value: | Dropdown list | Select one of the following three modes in which the Snap executes:
|
Troubleshooting
Error | Reason | Resolution |
---|---|---|
| The schema name is required for Snowpipe Streaming. | Provide a schema name in the Snap configuration. |
...
Excluding Fields from the Input Data Stream
We can exclude the unrequired fields from the input data stream by omitting them in the Input schema fieldset. This example demonstrates how we can use the <Snap Name> to achieve this result:
<screenshot of Pipeline/Snap and description>
Download this Pipeline.
Downloads
...
Download and import the pipeline into the SnapLogic application.
...
Snap
...
Provide pipeline parameters, as applicable.
Attachments | ||||
---|---|---|---|---|
|
Snap Pack History
Expand | ||||||
---|---|---|---|---|---|---|
| ||||||
|
Related Content
...
Endpoint Doc Link 1
...
Endpoint Doc Link 2
...
|
...
Related Content
...