snowflake.core.pipe¶

Manages Snowflake Pipes.

Example

>>> pipes: PipeCollection = root.databases["mydb"].schemas["myschema"].pipes
>>> mypipe = pipes.create(Pipe("mypipe"))
>>> pipe_iter = pipes.iter(like="my%")
>>> pipe = pipes["mypipe"]
>>> an_existing_pipe = pipes["an_existing_pipe"]

Refer to snowflake.core.Root to create the root.

Classes


`Pipe`(*, name[, comment, auto_ingest, ...])	A model object representing the Pipe resource.
`PipeCollection`(schema)	Represents the collection operations of the Snowflake Pipe resource.
`PipeResource`(name, collection_class)	Represents a reference to a Snowflake pipe.