Create, Verify, and Refresh a Pipe
A 3-step recipe with Snowflake. We can help you get access.
Recipe · 3 steps
Create, Verify, and Refresh a Pipe
with Snowflake
Create a pipe, fetch it to confirm, then refresh it to queue staged files.
- Create the pipe with its COPY INTO definition.
- Describe the pipe to confirm it was created.
- Refresh the pipe to queue staged files for ingestion.
What you'll need to have ready
- authToken: Bearer token (KEYPAIR_JWT, OAUTH, or programmatic access token).
- tokenType: Value for the X-Snowflake-Authorization-Token-Type header.
- databaseName: Database that holds the schema and pipe.
- schemaName: Schema that holds the pipe.
- pipeName: Name of the pipe to create.
- copyStatement: The COPY INTO statement that defines the pipe.
- comment: Optional comment applied to the pipe.
For your developer
Arazzo workflow snowflake:create-and-refresh-pipe, 3 operations: createPipe → fetchPipe → refreshPipe. Specs on APIs.io.