DataTrust-MCP企业连接器
LLM驱动的数据集成通过模型上下文协议。
Das问题
公司数据是孤立的:ERP,CRM,会计,Excel列表。系统之间的手动数据传输每周花费数小时并产生错误。现有的集成解决方案要么太昂贵(企业iPaaS),要么太有限(Zapier用于复杂逻辑)。
解决方案
MCP服务器,允许LLM代理直接访问业务数据。用于常见系统的连接器 + 用于数据质量和合规性的信任层。
建筑
特性
| 功能 | 描述 | MCP 工具 |
|---|---|---|
| 连接器 | Excel、CSV、JSON、Odoo、HubSpot、PostgreSQL、MySQL | list_connectors, read_records, write_records |
一致性检查 两个系统之间的数据匹配 compare_records | ||
| 变化检测 自从X以来发生了什么变化? | detect_changes, create_snapshot | |
| 审计跟踪 谁改变了什么时候? | query_audit_log | |
对账 自动结算(例如付款)↔ 账单)。 reconcile_records |
快速开始
# Clone & Install
git clone https://github.com/aliuyar1234/datatrust.git
cd datatrust
pnpm install
pnpm build
# Server starten
node packages/mcp-server/dist/cli.js --config config.json最小 配置config.json):
{
"$schema": "./schemas/datatrust.config.schema.json",
"server": { "name": "my-connectors", "version": "1.0.0" },
"connectors": [
{
"id": "invoices",
"type": "csv",
"filePath": "./data/invoices.csv"
},
{
"id": "customers",
"type": "hubspot",
"accessToken": "${HUBSPOT_ACCESS_TOKEN}",
"objectType": "contacts"
}
]
}配置功能:
- 在启动时扩展字符串中的环境变量:
${ENV_VAR}和${ENV_VAR:-default}(缺少变量 => fail-fast)。 - 可选HTTP传输:
server.transport = "http"(终点:/mcp,/healthz,/metrics). - Optionaler治理层:
server.policy(工具/连接器允许清单、现场屏蔽、书面批准+可审计决策)。
第一个命令(在LLM):
Lies alle Rechnungen über 1000€ aus dem invoices-Connector用例
1. 系统之间的数据匹配
Vergleiche Kunden in Odoo mit Kontakten in HubSpot.
Zeige mir alle, die nur in einem System existieren.→ compare_records 查找不一致,显示缺失的记录和字段差异。
2.变更跟踪
Was hat sich in der Kundendatenbank seit gestern 18:00 geändert?→ detect_changes 使用时间戳字段或快照比较。
3. 支付结算
Matche den Bankauszug mit offenen Rechnungen.
Toleranz: ±0.01€, Datum ±7 Tage.→ reconcile_records 具有可配置的匹配规则和信任分数。
包裹
| 包装 | 描述 |
|---|---|
@datatrust/core | 接口、类型、过滤器实用程序 |
@datatrust/connector-file | CSV、JSON、Excel |
@datatrust/connector-api | 奥多,HubSpot |
@datatrust/connector-db | PostgreSQL、MySQL |
@datatrust/trust-core | 数据信任层 |
@datatrust/entity-resolution | 相似性/模糊匹配实用程序 |
@datatrust/mcp-server | MCP服务器实现 |
筛选器语法
{
"where": [
{ "field": "amount", "op": "gt", "value": 1000 },
{ "field": "status", "op": "eq", "value": "open" }
],
"orderBy": [{ "field": "date", "direction": "desc" }],
"limit": 100
}操作: eq, neq, gt, lt, gte, lte, contains, in
对账规则
{
"rules": [
{
"name": "amount",
"source_field": "amount",
"target_field": "total",
"operator": "equals_tolerance",
"weight": 40,
"tolerance": 0.01
},
{
"name": "reference",
"source_field": "reference",
"target_field": "invoice_number",
"operator": "similarity",
"weight": 35,
"similarity_algorithm": "jaro_winkler",
"similarity_threshold": 0.85
},
{
"name": "date",
"source_field": "booking_date",
"target_field": "due_date",
"operator": "date_range",
"weight": 25,
"date_range_days": 7
}
],
"min_confidence": 60
}操作: equals, equals_tolerance, contains, regex, similarity, date_range
发展
pnpm install # Dependencies
pnpm build # Build all packages
pnpm -r test # Run tests (27 tests)许可证
该项目根据 商业来源许可证1.1.
免费:
- 开发和测试
- 学习与教育
- 年收入低于10万欧元的组织的生产使用情况
2029年1月1日之后: 转换为MIT许可证(完全开源)。
看 通知.md 第三方许可证。
商业许可
对于年收入达到或超过10万欧元的组织的生产使用,需要商业许可证。
联系人: ali.uyar1@hotmail.com
存储库: https://github.com/aliuyar1234/datatrust
