Skip to main content

Pipelines API

Deploy and manage multi-engine data pipeline templates. Pipelines combine multiple database services into pre-configured topologies for AI/ML and analytics use cases.

Endpoints

MethodPathDescription
GET/pipelines/templatesList available templates
GET/pipelines/templates/{id}Get a template
POST/pipelinesDeploy a pipeline
GET/pipelinesList deployed pipelines
GET/pipelines/{id}Get pipeline details
DELETE/pipelines/{id}Delete pipeline and all services

Available Templates

TemplateIDServices
RAG Pipelinerag-pipelineKafka + PostgreSQL (pgvector) + Valkey
Recommendation Enginerecommendation-engineKafka + PostgreSQL + Valkey
Event Analyticsevent-analyticsKafka + OpenSearch + PostgreSQL

Deploy a Pipeline

curl -u $USER:$PASS -X POST https://api.foundrydb.com/pipelines \
-H "Content-Type: application/json" \
-d '{
"template_id": "rag-pipeline",
"name": "my-rag",
"zone": "se-sto1"
}'

Request Body

FieldTypeRequiredDescription
template_idstringYesTemplate identifier
namestringYesPipeline name (services get suffixes)
zonestringYesDeployment zone (e.g., se-sto1)
plan_namestringNoOverride default plan for all services
organization_idstringNoOrganization to own the pipeline

Response (201)

{
"id": "a1b2c3d4-...",
"template_id": "rag-pipeline",
"name": "my-rag",
"zone": "se-sto1",
"status": "deploying"
}

Get Pipeline Details

curl -u $USER:$PASS https://api.foundrydb.com/pipelines/$PIPELINE_ID

Returns full details including services, topology members, and connection parameters:

{
"status": "running",
"services": [...],
"members": [...],
"connections": [
{
"role": "kafka-ingestion",
"connections": {
"bootstrap_servers": "my-rag-kafka.abc123.db.foundrydb.com:9093",
"security_protocol": "SASL_PLAINTEXT"
}
},
{
"role": "vector-store",
"connections": {
"connection_uri": "postgresql://app_user@my-rag-pgvector.abc123.db.foundrydb.com:5432/defaultdb?sslmode=require"
}
}
]
}

Pipeline Statuses

StatusDescription
deployingServices are being provisioned
runningAll services are healthy
degradedSome services are unhealthy
deletingPipeline is being torn down

Tutorials