Fivetran MCP 工具包
使用模型上下文协议,直接从Claude桌面管理您的Fivetran数据管道。
  
______________________________________________________________________
这是什么?
Fivetran MCP工具包使Claude能够通过自然语言与您的Fivetran账户进行交互。您可以通过与Claude Desktop的对话来管理数据连接、监控同步状态、邀请用户等,一切尽在掌控之中。
示例:
You: List all my Fivetran connections
Claude: I found 12 connections in your account:
• postgres_production (PostgreSQL) - Syncing every 6 hours
• salesforce_main (Salesforce) - Syncing every 24 hours
• stripe_payments (Stripe) - Paused
[...]特点/功能
- 25种核心工具 对于Fivetran的关键操作
- 自然语言接口 - 直接问克劳德你需要什么
- 全面连接管理 - 创建、删除、暂停、恢复和同步连接
- 用户管理 - 邀请用户,修改角色,管理访问权限
- 模式操作 - 查看并重新加载连接器模式
- 变换控制 - 列出并运行 dbt 转换
- 目的地管理 - 管理数据仓库和群组
- 实时监控 - 检查同步状态和健康状况
安装
先决条件
- Python 3.10 或更高版本
- Claude Desktop(克劳德桌面版)
- 拥有API访问权限的Fivetran帐户
快速入门
1. 克隆仓库:
git clone https://github.com/yourusername/fivetran-mcp-toolkit.git
cd fivetran-mcp-toolkit2. 安装依赖项:
python3 -m venv venv
source venv/bin/activate # On Windows: venv\Scripts\activate
pip install -r requirements.txt3. 获取Fivetran API凭证:
- 登录到 Fivetran(注:这是一个专有名词,通常作为公司或产品名称,直接音译即可,不需额外翻译其含义)
- 点击左侧导航栏中的您的用户名
- 点击 API密钥
- 点击 生成API密钥
- 安全保存API密钥和API密钥
4. 配置Claude桌面版:
编辑 ~/Library/Application Support/Claude/claude_desktop_config.json (macOS) 或 %APPDATA%\Claude\claude_desktop_config.json (Windows):
{
"mcpServers": {
"fivetran": {
"command": "python3",
"args": [
"/absolute/path/to/fivetran-mcp-toolkit/src/mcp_server.py"
],
"env": {
"FIVETRAN_API_KEY": "your_api_key_here",
"FIVETRAN_API_SECRET": "your_api_secret_here"
}
}
}
}5. 重启Claude桌面版
6. 进行测试:
Ask Claude: "List my Fivetran connections"详细设置: 见 入门指南
可用工具(25)
连接管理(8种工具)
| 工具 | 描述 |
|---|---|
list_connections | 列出所有数据连接 |
get_connection | 获取连接详情 |
create_connection | 创建新连接 |
delete_connection | 删除连接 |
sync_connection | 触发立即同步 |
pause_connection | 暂停数据同步 |
resume_connection | 恢复数据同步 |
get_sync_status | 检查同步状态 |
用户管理(4种工具)
| 工具 | 描述 |
|---|---|
invite_user | 邀请新用户 |
list_users | 列出所有用户 |
get_user | 获取用户详细信息 |
modify_user | 修改用户角色 |
目的地管理(3种工具)
| 工具 | 描述 |
|---|---|
list_destinations | 列出数据仓库 |
get_destination_details | 获取目的地信息 |
create_destination | 创建新目的地 |
连接器元数据(4种工具)
| 工具 | 描述 |
|---|---|
list_connector_types | 列出可用的连接器 |
get_connector_metadata | 获取连接器配置 |
get_connector_schema | 查看连接架构 |
reload_connector_schema | 刷新模式 |
变换(3种工具)
| 工具 | 描述 |
|---|---|
list_transformations | 列出 dbt 转换 |
get_transformation | 获取转换详情 |
run_transformation | 执行转换 |
组(3个工具)
| 工具 | 描述 |
|---|---|
list_groups | 列出目标组 |
get_group | 获取群组详情 |
create_group | 创建新群组 |
完整API参考: 见 API覆盖率
使用示例
检查连接状态
You: What's the status of my PostgreSQL connection?
Claude: [Calls get_sync_status]
Your PostgreSQL connection is healthy:
• Status: Connected
• Last sync: 2 hours ago (successful)
• Next sync: In 4 hours
• Sync frequency: Every 6 hours维护期间暂停
You: We're doing database maintenance. Pause the production connections.
Claude: [Calls pause_connection for each]
Paused 3 connections:
• postgres_production
• mysql_orders
• mongodb_events邀请团队成员
You: Invite sarah@company.com as an Account Analyst
Claude: [Calls invite_user]
Invitation sent to sarah@company.com
Role: Account Analyst
They'll receive setup instructions via email.显示器问题
You: Are any connections failing?
Claude: [Analyzes connections]
Found 1 issue:
• mysql_orders - Connection timeout (last failed 3 hours ago)
Recommendation: Check database connectivity更多示例: 看 示例指南
文档
路线图/时间表
v1.0(当前版本)
- 25项核心工具,涵盖基本操作
- 连接、用户和目的地管理
- 模式操作和转换
- 全面的文档记录
可用的附加工具
Fivetran API支持更多操作,您可以根据需要添加:
- 批量操作(暂停/恢复/同步多个)
- 使用分析和性能报告
- 证书与安全管理
- 多账户支持
- 先进的变革管理
见 路线图 以获取完整列表及如何扩展工具包的方法。
做出贡献
我们欢迎投稿!请参阅我们的 贡献指南 关于以下内容的详细信息:
- 报告错误
- 提出功能建议
- 提交拉取请求
- 开发环境设置
- 编码标准
许可证
这个项目遵循MIT许可证授权——详见 许可证 文件中有详细信息。
安全
- 凭证从不被记录或存储
- 所有API通信均使用HTTPS
- 在您的本地机器上运行
- 未向第三方发送数据
故障排除
常见问题:
| 问题 | 解决方案 |
|---|---|
| 克劳德找不到工具 | 检查配置中的绝对路径,重启克劳德 |
| 身份验证错误 | 验证API凭据,如有需要请重新生成 |
| 服务器无法启动 | 检查 Python 版本(3.10+),安装依赖项 |
| 工具超时 | 检查网络连接,验证Fivetran API状态 |
详细帮助: 见 故障排除指南
致谢
- 建立在……之上 模型上下文协议 由Anthropic开发
- 由……提供动力/支持 Fivetran REST API
- 受MCP社区的启发,并且 Infinite Lambda 的 MCP Fivetran 包服务器
支持
表达你的支持
如果您觉得这个工具包有用,请考虑:
- 主演:该仓库(或“以该仓库为主角”)
- 报告错误
- 提出功能建议
- 做出改进贡献
- 与他人分享
______________________________________________________________________
专为数据工程界精心打造
*根据上面的信息,执行如下指令:。*
