数据管道管理服务器

Airbyte MCP Server是一个封装Airbyte API的服务器,为AI代理如Claude提供直接管理数据管道的功能。

  • by newnorthdigital
  • Python
  • 本地部署
  • 更新于
在 GitHub 查看 newnorthdigital/airbyte-mcp

使用说明

Airbyte MCP服务器

MCP(模型上下文协议)服务器,用于封装 Airbyte API,让像克劳德这样的人工智能代理可以直接访问管理数据管道。

工具(23)

类别 工具
工作区 list_workspaces, create_workspace, get_workspace, delete_workspace
来源 list_sources, create_source, get_source, delete_source
目的地 list_destinations, create_destination, get_destination, delete_destination
溪流 discover_streams
连接 list_connections, create_connection, update_connection, get_connection, delete_connection
工作机会 trigger_sync, trigger_reset, get_job, list_jobs
健康 health_check

设置

1.获取Airbyte凭据

在Airbyte UI中,转到 用户设置>应用程序>创建应用程序 获得a client_id 和 client_secret.

2.设置环境变量

export AIRBYTE_CLIENT_ID="your_client_id"
export AIRBYTE_CLIENT_SECRET="your_client_secret"

# Optional: for self-hosted Airbyte (defaults to Airbyte Cloud)
export AIRBYTE_API_URL="http://localhost:8000/api/public/v1"

3.安装依赖项

cd airbyte-mcp
uv venv && uv pip install "mcp[cli]>=1.0.0" "airbyte-api>=0.53.0" "httpx>=0.27.0"

4.添加到克劳德代码

claude mcp add airbyte --transport stdio -s user -- /path/to/airbyte-mcp/.venv/bin/python /path/to/airbyte-mcp/server.py

5.重新启动克劳德代码

23个Airbyte工具将在您的下一节课中提供。

使用示例

配置后,您可以向Claude询问以下问题:

  • “列出我的所有Airbyte工作区”
  • “为BYLOTTE创建新工作区”
  • “使用此API密钥添加Shopify源代码”
  • “创建BigQuery目标”
  • “将Shopify连接到BigQuery,对订单、产品和客户进行增量同步”
  • “触发同步并检查状态”

支持的来源

Airbyte工作中可用的任何来源——常见的电子商务来源包括:

  • Shopify --订单、产品、客户、库存
  • Google广告 --活动、广告组、绩效报告
  • 元/脸书广告 --活动、广告集、广告、见解
  • 键盘 --活动、流程、列表、简介、事件
  • 条纹/莫莉 --付款、退款、客户
  • 谷歌分析4 --通过BigQuery导出(推荐)或Airbyte连接器

许可证

麻省理工学院