Ontology Mcp Server

Ontology MCP 服务

将 ISO 20022 银行消息转换为可查询的知识图谱——任何 AI Agent 都可通过 MCP 访问。

银行、金融科技公司和支付处理商每天都会处理数千条 ISO 20022 消息（pacs.008 付款、camt.056 撤销、camt.029 响应）。这些 XML 文件内容密集、相互关联，几乎无法跨文件查询——直到现在。

Ontology 可导入 ISO 20022 XML，提取结构化金融信号，构建 RDF 知识图谱，并将其作为原生工具开放，供任何兼容 MCP 的 AI Agent 使用。

pip install ontology-mcp
python mcp_server.py
# Connect Claude Desktop, Cursor, or any MCP client

---

为什么要做这个项目

ISO 20022 是全球金融消息传递标准。每一笔付款、结算、撤销和对账单都通过它传递。但这些数据却被困住了：

• XML 无法查询——要找出“所有涉及 BLUEUSNY 且金额超过 50,000 美元的交易”，就得在文件中逐一 grep
• 消息彼此关联——camt.056 撤销消息会引用 pacs.008 付款消息，但它们位于不同的 XML 文件中，彼此没有关联
• AI Agent 无法使用这些数据——即使使用 RAG，结构化金融数据也难以通过简单分块处理

Ontology 通过构建具有类型、彼此关联的知识图谱和自然语言界面，解决了以上所有问题。

---

快速开始

Docker（最简单）

docker pull ghcr.io/mrcholis/ontology-mcp:latest
docker run ghcr.io/mrcholis/ontology-mcp

或者运行演示：

docker run ghcr.io/mrcholis/ontology-mcp python demo.py

使用 pip 安装

pip install ontology-mcp
# Or with persistent storage:
pip install "ontology-mcp[oxigraph]"

2. 运行演示

python -m ontology_mcp.demo

此操作会加载示例 ISO 20022 消息，并展示知识图谱的样子。

3. 启动服务

python mcp_server.py

4. 连接到 Claude Desktop

将以下内容添加到 claude_desktop_config.json：

{
  "mcpServers": {
    "ontology": {
      "command": "python",
      "args": ["/path/to/ontology-mcp/mcp_server.py"]
    }
  }
}

重启 Claude。现在你可以这样提问：

“从我的 messages 文件夹加载 XML 文件，并找出所有涉及 BLUEUSNY、金额超过 50,000 美元的交易。”

“撤销案件 20220718USDDSA9407803873 的完整生命周期是什么？”

“加载的数据中是否存在异常或余额不匹配？”

---

可以做什么

工具	功能
extract_and_map	解析 ISO 20022 XML → 信号 → RDF，并合并到知识图谱中
load_xml_file	从磁盘加载并处理 XML 文件
load_output_directory	从文件夹加载所有预构建的 .ttl 文件
query_lifecycle	查询某个案件 ID／交易 ID／BIC 的完整消息链
sparql_query	对知识图谱运行任意 SPARQL 查询
find_anomalies	标记高价值交易、被拒绝的撤销请求和余额不匹配
get_institution_activity	查询某个 BIC 代码的所有消息及按类型汇总的总数
graph_stats	查询三元组数量、信号细分统计和 BIC 清单
start_stream_server	启动 WebSocket 服务，以流式方式导入 XML
push_stream_message	通过 WebSocket 实时推送 XML 消息

支持的消息类型

消息	说明
pacs.008	付款发起（金融机构 → 金融机构）
pacs.009	付款结算
camt.053	账户对账单
camt.054	借记／贷记通知
camt.056	撤销请求
camt.026	无法执行
camt.029	撤销响应／处理结果

---

架构

ISO 20022 XML
    |
    v
FinancialSignalExtractionPipeline   → extracts typed Python signal objects
    |
    v
FinancialSignalToRDFMapper          → maps signals to RDF triples
    |
    v
RDF Knowledge Graph (rdflib / Oxigraph)
    |  queryable via SPARQL
    v
MCP Tools (mcp_server.py)           → exposed over stdio transport
    |
    v
AI Agent / Claude Desktop

持久化存储使用 Oxigraph（基于 RocksDB）。如果未安装 Oxigraph，则回退到内存中的 rdflib。

---

示例

查询完整付款生命周期

User: What happened with cancellation case 20220718USDDSA9407803873BLUEUSNY001?

Agent: I found 4 messages in the lifecycle:

  1. pacs.008 — Payment initiated (BLUEUSNY → FEDNYUSS)
     $94,078.03 USD on 2022-07-18

  2. camt.056 — Cancellation requested by BLUEUSNY
     Reason: duplicate submission

  3. camt.029 — Cancellation rejected
     Reason: payment already settled

  4. camt.026 — Unable to apply notification sent to BLUEUSNY

查找异常

User: Are there any unusual transactions?

Agent: Found 4 high-value transactions (>$50K):
  - TXN_20220718_001: $94,078.03 (BLUEUSNY → FEDNYUSS)
  ...

Found 1 rejected cancellation:
  - Case 20220718USDDSA9407803873: rejected (already settled)

---

开发

git clone https://github.com/mrcholis/ontology-mcp
cd ontology-mcp
python3.11 -m venv venv311
source venv311/bin/activate
pip install -e ".[all]"

# Run tests
python _test_mcp_v2.py

---

路线图

• 支持 ISO 20022 消息（pacs.008/009、camt.053/054/056/026/029）
• Oxigraph 持久化存储
• WebSocket 流式导入
• 生产环境 IRIs（替换 http://example.org/ 命名空间）
• SPARQL HTTP 端点
• pain.001 / pain.002 付款发起消息
• 提供 Docker 镜像，实现一键部署

---

许可证

MIT