fivetran-mcp

Fivetran MCP Server

注記： このリポジトリは、Anthropic の AI コーディングアシスタントである Claude Code によってのみ構築・保守されています。

Fivetran のデータパイプラインを操作するための、MCP（Model Context Protocol） サーバーです。Claude などの AI アシスタントが、自然言語を通じて同期を管理し、接続ステータスを監視し、データパイプラインを制御できるようにします。

機能

• 接続の一覧表示 - ステータスとともに、すべての Fivetran 接続を表示します
• 同期ステータスの確認 - タスクや警告など、任意の接続の詳細なステータスを取得します
• 同期の開始 - 必要に応じて同期を開始します
• 履歴の再同期 - データ全体の再同期、または特定のテーブルの再同期を開始します
• 一時停止／再開 - 接続のスケジュールを制御します
• グループの一覧表示 - すべての宛先グループを表示します
• 接続のテスト - 接続性や設定の問題を診断します
• スキーマの表示 - 任意の接続のスキーマ、テーブル、カラムを表示します
• スキーマの再読み込み - ソースからスキーマ設定を更新します

クイックスタート

ステップ 1：Fivetran API 認証情報を取得する

1. Fivetran Dashboard にログインします
2. username（右上隅）をクリックします
3. API Key をクリックします
4. Generate API key をクリックします
5. API Key と API Secret の両方をコピーします（シークレットは一度しか表示されません！）

詳しくは、Fivetran API 入門ガイドをご覧ください。

ステップ 2：認証情報を保存する

~/.env.local（または同等のファイル）に追加します：

# Fivetran API
export FIVETRAN_API_KEY="your-api-key"
export FIVETRAN_API_SECRET="your-api-secret"

その後、再読み込みします：

source ~/.env.local

ステップ 3：認証情報を確認する

認証情報が機能することをテストします：

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)"

期待される応答：

{"code":"Success","data":{"account_id":"...","account_name":"..."}}

ステップ 4：Claude Code を設定する

~/.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}"
      }
    }
  }
}

ステップ 5：Claude Code を再起動する

新しい MCP サーバーを読み込むために、Claude Code を再起動します。これで Fivetran のツールを利用できるようになります。

利用可能なツール

接続管理

ツール	説明
list_connections	すべての接続を一覧表示します。グループで絞り込むこともできます
get_connection_status	タスク、警告、同期の詳細を含む、詳細なステータスを取得します
trigger_sync	接続の同期を開始します（任意の force フラグを指定できます）
trigger_resync	履歴全体の再同期を開始します
resync_tables	特定のテーブルのみ再同期します（例：["schema.table_name"]）
pause_connection	接続を一時停止します
resume_connection	一時停止中の接続を再開します
list_groups	すべてのグループ／宛先を一覧表示します
test_connection	接続性や設定の問題を特定するための診断テストを実行します

スキーマとテーブルの表示

ツール	説明
get_connection_schema	テーブルの絞り込みを任意で指定してスキーマ情報を取得します（絞り込み時はカラムも含まれます）
get_schema	接続の完全な生スキーマ設定を取得します
list_tables	有効状態と同期モードを含む、すべてのテーブルを一覧表示します
get_table_columns	特定のテーブルのカラム詳細を取得します
reload_schema	ソースからスキーマ設定を更新します

制限事項

以下の機能は、Fivetran の REST API では利用できません。

機能	状態	備考
カラムのデータ型	利用不可	型情報は接続先のデータベースに直接問い合わせてください
同期履歴／ログ	利用不可	Fivetran はログサービスを使用し、外部の接続先にストリーミングします
過去の同期に関する詳細なエラーログ	利用不可	現在のタスク／警告のみアクセスできます
行レベルの同期ステータス	利用不可	API では公開されていません
データ品質メトリクス	利用不可	API では公開されていません

同期ログや履歴データを取得するには、Fivetran のログサービスを設定して、ログをデータウェアハウスにストリーミングすることを検討してください。

環境変数

サーバーでは、次の 2 つの命名規則をサポートしています。

推奨	代替
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

クラウドへのデプロイ

Cloudflare Workers（無料）

ホストされた MCP エンドポイントとして Cloudflare Workers にデプロイします。

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

詳しい手順については、cloudflare/README.mdを参照してください。

ライセンス

MIT