Snowflake · Capability

Snowflake Data Engineering

Unified workflow for building and managing data pipelines using SQL execution, tasks, streams, pipes, stages, and functions. Used by Data Engineers to orchestrate ETL/ELT workflows and continuous data ingestion.

Run with Naftiko SnowflakeData EngineeringETLData Pipelines

What You Can Do

POST
Submit statement — Submit a SQL statement
/v1/statements
GET
List tasks — List tasks
/v1/tasks
POST
Create task — Create a task
/v1/tasks
GET
List streams — List streams
/v1/streams
POST
Create stream — Create a stream
/v1/streams
GET
List pipes — List pipes
/v1/pipes
POST
Create pipe — Create a pipe
/v1/pipes
GET
List stages — List stages
/v1/stages
POST
Create stage — Create a stage
/v1/stages

MCP Tools

submit-sql

Submit a SQL statement for execution

get-statement-status

Get status of a submitted statement

read-only
cancel-statement

Cancel a running statement

list-tasks

List scheduled tasks

read-only
create-task

Create a scheduled task

execute-task

Execute a task immediately

resume-task

Resume a suspended task

suspend-task

Suspend a running task

list-streams

List change data capture streams

read-only
create-stream

Create a CDC stream

list-pipes

List data ingestion pipes

read-only
create-pipe

Create a pipe for continuous ingestion

refresh-pipe

Refresh a pipe

list-stages

List data loading stages

read-only
create-stage

Create a stage

list-stage-files

List files in a stage

read-only
list-functions

List functions

read-only
create-function

Create a function

execute-function

Execute a function

list-procedures

List stored procedures

read-only
create-procedure

Create a stored procedure

call-procedure

Call a stored procedure

list-udfs

List user defined functions

read-only
get-query-result

Get a query result

read-only

APIs Used

snowflake-sql snowflake-task snowflake-stream snowflake-pipe snowflake-stage snowflake-function snowflake-procedure snowflake-udf snowflake-result