Snowflake - Snowpipe Operation



This tool is used to connect to Snowpipe REST API and perform operations.


Parameter Mandatory Description



Name given to the tool.

Snowpipe Name


Valid Snowpipe name for which you want to execute the Snowipipe API call.

File Names


Name of the file to ingest. Mutliple file names can be separated by the pipe character '|'.



Type of operation to execute. Possible options are:

  • ingestData: Sends an API request to the selected snowpipe to ingest the files provided in in the File Names parameter. The files have to be first dropped on the stage used by the Snowpipe.

  • getStatusReport: Checks the status report for the listed files and depending on the Report Publication and Report Processing parameters, either returns it or processes it.

If the files are not processed for more than 2 minutes the tool throws a timeout exception.

Scripting Connection


Scripting connection that should be used by the scripting ations.

XPath Expression for Snowflake


Valid XPath expression used to reference the Snowflake metadata to use as target.

This expression can return any node of a Snowflake metadata.

Report Publication


Only applies to the getStatusReport operation.

Determines how to publish the API response. Possible options are:

* sessionVariable: The status report is published as a sessionVariable: SNOWPIPE_API_RESPONSE

* disable: The status is not published.

Report Processing


Only applies to the getStatusReport operation.

Determines how to process the report. Possible options are:

* Do not parse the report: There will be no processing of the report.

* Throw an error when the report contains loading failures: The tool raises an exception when at least one file from the list is not correctly ingested. The exception contains the error details regarding the file(s) that were not processed.