The Airbyte MCP server
Connect Airbyte to your AI assistant. Build new pipelines, fix failing syncs and fetch live data.
Airbyte MCP
Which of my Airbyte connections failed today, and how many rows did each sync last time?
airbyte · list_connections → get_job_status
2 of 14 connections failed in the last 24h:
| Connection | Status | Rows synced |
|---|---|---|
| Salesforce → Snowflake | Failed | 1,204,553 |
| Postgres → BigQuery | Failed | 382,190 |
| Stripe → Snowflake | Succeeded | 96,021 |
Airbyte MCP
Show the 3 newest records in the HubSpot contacts table.
airbyte · read_records(hubspot.contacts)
Here are the latest contact records, read live via Airbyte:
| id | updated_at | |
|---|---|---|
| 80412 | maya@acme.io | 09:42 UTC |
| 80409 | li@northwind.co | 09:17 UTC |
| 80398 | sam@globex.com | 08:55 UTC |
Claude
ConnectedYou
Why is my Salesforce → Snowflake sync failing?
Airbyte MCP
"Salesforce → Snowflake (prod)" failed 3 runs. Cause: expired OAuth token. Want a re-authentication link?
You
Do it.
Airbyte MCP
Here's your re-authentication link. I'll re-run the sync once it's valid.
[01]
In Claude or ChatGPT, open connector settings and add a custom MCP connector.
[02]
Paste the Airbyte MCP server URL and sign in with your Airbyte Cloud account.
[03]
“List my connections and tell me which failed in the last day.”
Built for production
Databases, APIs and files. Batch, incremental and CDC, one catalog for pipelines and agents.
Deploy sources and destinations, select streams, schedule and start syncs through conversation.
Read job logs, check configs and get failures explained, with a suggested fix.
The agent acts on your behalf with the exact access you already have in Airbyte.
With the context layer on, query sources and destinations directly, no waiting on a sync.
Every tool is classified read, mutate or destruct, and every action is audit-logged.
Works with every edition of Airbyte Cloud. Management tools are free to use.