Pipeline canvasTransforms & logicAIInsightsUnder the hoodArchitecture
The product

One pipeline.
One graph, one canvas.

A pipeline is a single graph: source and destination nodes connected by an edge, with transforms chained downstream of whatever just landed. AI builds alongside you and takes on delegated tasks. It’s all the same canvas, versioned together, and Insights watches what it does — no separate ingest tool, orchestrator and monitoring stack to reconcile.

Pipeline canvas

Connect anything, in minutes.

A source node and a destination node, joined by an edge — that edge is the sync. Pre-built connectors for the databases and SaaS apps you already use, or point the AI at any API’s documentation and get a working connector back.

  • 200+ pre-built connectors — databases, SaaS, files, event streams
  • Paste API docs or upload a spec — the AI generates a working connector
  • Incremental and full-refresh sync modes, schema drift handled for you
Add a component
AllConnectorsTransformCompute
Search components
Postgres
Source · Destination
MySQL
Source · Destination
Stripe
Source
Salesforce
Source
HubSpot
Source
Google Sheets
Source · Destination
Snowflake
Destination
BigQuery
Destination
Amazon S3
Source · Destination
No connector for it? Build one from its docs
https://docs.acme-billing.dev/api/v2Generate
customersinvoicessubscriptionspayouts4 streams · auth: API key · paginated
Transforms & logic

Chain, schedule, and version the whole graph.

Downstream of any destination, chain SQL, dbt, branches, and scripts against the data that just landed — on the same canvas as the sync that fed it. Every save is a version; promote to production instantly, no branches to manage.

  • Drag-and-drop canvas with a live copilot rail alongside it
  • Cron scheduling, or near-real-time: transforms fire the moment a sync lands new rows
  • Instant version promotion — optional Git sync mirrors published versions out
Orders → revenueNear real-timeDeployed · v14
Sync · 4 streams · CDC
Source
Postgres — shop
Read 2,114 rows
Destination
Snowflake — prod
Loaded 2,114 rows
SQL query
daily_revenue
31 rows · 2.4s
Sync from another pipeline
Stripe → Snowflake
Landed 3 min ago
dbt build
finance models
12 models passed
Slack notification
Post summary
Skipped · no change
SQL query
daily_revenue
Snowflake — prod
select date(created_at) as day,
       sum(amount) as revenue
from   shop.orders
group by 1
New rows land upstream
Retry 3× · then notify
AI

A copilot that builds with you, and an agent you can delegate to.

Describe what you want in plain language on the canvas, or hand off a whole task to an agent — it drafts a diff against the current version and waits for your review before anything ships.

  • Copilot proposes the next step and explains its reasoning as you build
  • Delegated agent tasks run in the background, flag ambiguity, wait for review
  • Nothing merges into version history without a human approval
Agent tasks+ New task
Backlog2
Add a HubSpot → Snowflake syncQueued
Backfill 2024 invoicesQueued
In progress1
Build Stripe → warehouse billing syncA worker is on this
Needs review1
Sentiment-tag support ticketsReady for your review+3 steps · 1 new sync
ApproveReject
Done2
Rewrite SLA compliance calcApproved 2h ago
Alert on failed payoutsApproved yesterday
Insights

See what your data is doing, and hear when it’s wrong.

Every sync is already on a ready-made Overview: records loaded, failures, freshness, rejected rows. Query it or your own warehouse, lay the results out as dashboards, and let monitors learn what’s usual so you hear about the day it isn’t.

  • SQL or a no-code builder, on Pipeloom’s data for free or on Postgres, Snowflake, BigQuery and Redshift
  • Built-in monitors on every connection, plus your own on any saved query — tried on the last 30 days before you save
  • Alerts by email, Slack or webhook — or start a pipeline to fix it, like a re-sync or a backfill
  • Each environment sees only its own data; dashboards and monitors move to production in a release
Insights / RevenueLast 30 daysMonitor · Alerting
Revenue · 30 days$418.0k+4.2% vs prior 30 days
Orders12,408+2.8%
Average order$33.69+1.4%
Daily revenue Usual range Would have alerted · 1 in 30 days
Sep 5Oct 5
Anomaly · Sep 23
Daily revenue unusual
$3.1k · usual $11.2k–$16.4k
Slack #finance · 2 emails
Re-sync orders · run #212
Under the hood

Built for teams, not just individual builders.

Version history

Every save is a version. Compare, promote, or roll back instantly — no branches or merge conflicts.

Environments

Staging and production, isolated. Promote a version between them when it’s ready.

Secrets management

Credentials stored and rotated centrally, referenced by pipelines — never pasted into plaintext config.

RBAC & SSO

Role-based access per workspace, SAML/SSO on Enterprise. Everyone gets a seat, not a per-connector fee.

Architecture

How it fits together

CONTROLDATAsave · deploysame API, your accesscompiled flowstarts syncsSQL · dbtreadloadCanvasbuild · version · runCopilot agentacts with your permissionsPipeloom control planepipeline graph + versionsvalidation · one owner per syncsecrets · schedulesruns + logsPipeline engineruns the graphSQL · dbt · branchesfires on new rowsYour sourcesdatabases · SaaS · filesSync workersconnector runtime · CDCYour warehouseSnowflake · BigQuery · Postgres

See it on your own data.

Free to start. Connect a source and build your first pipeline in minutes.