Pipe

List pipes

GET/api/v2/databases/{database}/schemas/{schema}/pipes
List pipes

路径参数

参数描述
database string
Identifier (i.e. name) for the database to which the resource belongs. You can use the `/api/v2/databases` GET request to get a list of available databases.
schema 
Identifier (i.e. name) for the schema to which the resource belongs. You can use the `/api/v2/databases/{database}/schemas` GET request to get a list of available schemas for the specified database.

查询参数

参数描述
like string
Query parameter to filter the command output by resource name. Uses case-insensitive pattern matching, with support for SQL wildcard characters.

响应

代码描述
200
successful
202
Successfully accepted the request, but it is not completed yet.

Create a pipe

POST/api/v2/databases/{database}/schemas/{schema}/pipes
Create a pipe

查询参数

参数描述
createMode string
Query parameter allowing support for different modes of resource creation. Possible values include:
  • errorIfExists: Throws an error if you try to create a resource that already exists.
  • orReplace: Automatically replaces the existing resource with the current one.
  • ifNotExists: Creates a new resource when an alter is requested for a non-existent resource.

响应

代码描述
200
Successful request.
202

Fetch a pipe

GET/api/v2/databases/{database}/schemas/{schema}/pipes/{name}
Fetch a pipe

路径参数

参数描述
name 
Identifier (i.e. name) for the resource.

响应

代码描述
200
successful
202

Delete a pipe

DELETE/api/v2/databases/{database}/schemas/{schema}/pipes/{name}
Delete a pipe

查询参数

参数描述
ifExists boolean
Query parameter that specifies how to handle the request for a resource that does not exist:
  • true: The endpoint does not throw an error if the resource does not exist. It returns a 200 success response, but does not take any action on the resource.
  • false: The endpoint throws an error if the resource doesn't exist.

响应

代码描述
200
202

Refresh the pipe

POST/api/v2/databases/{database}/schemas/{schema}/pipes/{name}:refresh
Refresh the pipe

查询参数

参数描述
prefix string
Path (or prefix) appended to the stage reference in the pipe definition. The path limits the set of files to load.
modified_after string
Timestamp (in ISO-8601 format) of the oldest data files to copy into the Snowpipe ingest queue based on the LAST_MODIFIED date (i.e. date when a file was staged)

响应

代码描述
200
202
语言: 中文