Skip to main content

CREATE PIPE

Creates a pipe backed by a COPY INTO <table> statement.

Syntax

CREATE PIPE [ IF NOT EXISTS ] <name>
[ AUTO_INGEST = TRUE ]
[ COMMENT = '<comment>' | COMMENTS = '<comment>' ]
AS
COPY INTO <table> ...

Parameters

ParameterDescription
IF NOT EXISTSOptional. Succeeds without changes if the pipe already exists.
AUTO_INGEST = TRUEOptional. Enables automatic ingestion.
COMMENT / COMMENTSOptional pipe comment.
AS COPY INTO ...The COPY INTO <table> statement executed by the pipe.

Example

CREATE PIPE IF NOT EXISTS my_pipe
AUTO_INGEST = TRUE
COMMENTS = 'load staged files into target table'
AS
COPY INTO my_table
FROM @my_stage;
Try Databend Cloud for FREE

Multimodal, object-storage-native warehouse for BI, vectors, search, and geo.

Snowflake-compatible SQL with automatic scaling.

Sign up and get $200 in credits.

Try it today