Create Pipeline

Use this route to create a new data pipeline. A pipeline defines the data extraction process from a connection, including scheduling, transformations, and output configuration.

How to use

Send the pipeline details in the request body.

Payload example

{
  "name": "Daily Customer Sync",
  "description": "Syncs customer data from PostgreSQL daily",
  "type": "sync",
  "connection_id": "conn-abc-123",
  "cron": "0 0 * * *",
  "connector_name": "PostgreSQL",
  "connector_plugin": "postgresql",
  "connector_version": "1.0.0",
  "image_url": "https://assets.dadosfera.ai/images/connectors/postgresql.svg",
  "input_id": "input-xyz-456",
  "transformations_ids": ["transform-001"],
  "tags": ["production", "customers"],
  "properties": {}
}

Body fields

• name (required): display name for the pipeline;
• description (required): description of the pipeline;
• type (required): pipeline type (e.g., sync, upload);
• connection_id (required): ID of the connection to use as data source;
• cron (required): cron expression for scheduling (e.g., 0 0 * * * for daily, @once for one-time);
• connector_name (required): name of the connector;
• connector_plugin (required): plugin identifier for the connector;
• connector_version (required): version of the connector;
• image_url (required): URL for the connector's icon image;
• input_id (optional): ID of the input configuration to use;
• transformations_ids (optional): array of transformation IDs to apply;
• tags (optional): array of tag strings;
• properties (optional): additional pipeline properties.

Error scenarios