Wraps the Fivetran REST API so you can manage data pipelines through Claude. You get the full operational toolkit: list connections and groups, check sync status with warnings and tasks, trigger syncs or historical resyncs for specific tables, pause and resume connections, and reload schemas from sources. It also exposes schema visibility with tools to inspect tables and columns. The setup requires a Fivetran API key and secret, which you pass through environment variables. If you're already running Fivetran connectors and want to kick off syncs, debug stuck pipelines, or inspect what's actually being ingested without opening the dashboard, this gives you that control through conversation.
Note: This repository is built and maintained entirely by Claude Code, Anthropic's AI coding assistant.
An MCP (Model Context Protocol) server for controlling Fivetran data pipelines. Enables AI assistants like Claude to manage syncs, monitor connection status, and control data pipelines through natural language.
See Fivetran API Getting Started for more details.
Add to your ~/.env.local (or equivalent):
# Fivetran API
export FIVETRAN_API_KEY="your-api-key"
export FIVETRAN_API_SECRET="your-api-secret"
Then reload:
source ~/.env.local
Test that your credentials work:
curl -s -X GET "https://api.fivetran.com/v1/account/info" \
-H "Accept: application/json" \
-H "Authorization: Basic $(echo -n "$FIVETRAN_API_KEY:$FIVETRAN_API_SECRET" | base64)"
Expected response:
{"code":"Success","data":{"account_id":"...","account_name":"..."}}
Add to your ~/.claude.json:
{
"mcpServers": {
"fivetran": {
"type": "stdio",
"command": "uvx",
"args": ["fivetran-mcp@latest"],
"env": {
"FIVETRAN_API_KEY": "${FIVETRAN_API_KEY}",
"FIVETRAN_API_SECRET": "${FIVETRAN_API_SECRET}"
}
}
}
}
Restart Claude Code to load the new MCP server. You should now have access to Fivetran tools.
| Tool | Description |
|---|---|
list_connections | List all connections, optionally filtered by group |
get_connection_status | Get detailed status including tasks, warnings, and sync details |
trigger_sync | Start a sync for a connection (optional force flag) |
trigger_resync | Trigger full historical resync |
resync_tables | Resync specific tables only (e.g., ["schema.table_name"]) |
pause_connection | Pause a connection |
resume_connection | Resume a paused connection |
list_groups | List all groups/destinations |
test_connection | Run diagnostic tests to identify connectivity/configuration issues |
| Tool | Description |
|---|---|
get_connection_schema | Get schema info with optional table filter (includes columns when filtering) |
get_schema | Get complete raw schema configuration for a connection |
list_tables | List all tables with enabled status and sync mode |
get_table_columns | Get column details for a specific table |
reload_schema | Refresh schema configuration from the source |
The following capabilities are not available via Fivetran's REST API:
| Capability | Status | Notes |
|---|---|---|
| Column data types | Not available | Query your destination database directly for type info |
| Sync history/logs | Not available | Fivetran uses Log Service which streams to external destinations |
| Detailed error logs for past syncs | Not available | Only current tasks/warnings are accessible |
| Row-level sync status | Not available | Not exposed via API |
| Data quality metrics | Not available | Not exposed via API |
For sync logs and historical data, consider setting up Fivetran's Log Service to stream logs to your data warehouse.
The server supports two naming conventions:
| Preferred | Alternative |
|---|---|
FIVETRAN_API_KEY | FIVETRAN_SYNC_API_KEY |
FIVETRAN_API_SECRET | FIVETRAN_SYNC_API_SECRET |
# Clone the repository
git clone https://github.com/YimingYAN/fivetran-mcp.git
cd fivetran-mcp
# Install dependencies
uv sync
# Run the server locally
uv run fivetran-mcp
Deploy to Cloudflare Workers for a hosted MCP endpoint:
cd cloudflare
uv tool install workers-py
npx wrangler login
npx wrangler secret put FIVETRAN_API_KEY
npx wrangler secret put FIVETRAN_API_SECRET
uv run pywrangler deploy
See cloudflare/README.md for detailed instructions.
FIVETRAN_API_KEY*secretFivetran API key
FIVETRAN_API_SECRET*secretFivetran API secret
com.mcparmory/google-sheets
domdomegg/google-sheets-mcp
henilcalagiya/google-sheets-mcp
cct15/war-dashboard-data
moooonad/mcp-google-sheets-full
io.github.br0ski777/csv-to-json