• 关系数据库 MySQLOracle达梦人大金仓openGauss
• 数据仓 DorisHiveCKStarRocks
• API 系统 ERPCRMMESPLM
• 文档 NASFTPSFTPMinIODMS
• 消息 KafkaPulsarRabbitMQ
• 搜索 ESOpenSearch
• 知识库 Confluence语雀Wiki
• 国产业务 泛微致远金蝶用友

testConnection()      // 连通性
discoverMetadata()    // 元数据扫描
previewData()         // 预览样例
readBatch()
readIncremental()
readCDC()
fetchPermissions()    // 权限血缘
fetchSchema()
fetchDocuments()
fetchChanges()

类型

table

行数

120,341

主键

customer_id

外键

industry_code → industry.code

更新字段

updated_at

负责人

sales_department

密级

L2 · 内部

• ● Customer 置信 0.94
• ● Organization 0.61
• ● Account 0.42

• Customer-belongsTo-Industry 0.92
• Customer-signs-Contract 0.78
• Customer-owns-Equipment 0.55

父概念

Organization · LegalEntity

命名空间

https://atlas/onto/customer360#

同义词

客户 · 甲方 · Buyer · Account

用途

面向销售、合同、信用、运营场景的统一客户语义

SHACL 约束

必填 name, industry · creditLimit ≥ 0 · level ∈ {Strategic,Key,Normal}

权限标签

data_scope · region · dept

工具绑定

get_customer_credit · create_follow_up · submit_contract

• Strategic A · 战略客户
• Key B · 重点客户
• Normal C · 普通客户
• Inactive D · 已流失

• v1.3 当前 2026-05-12
• v1.2 2026-03-20
• v1.1 2025-11-08
• v1.0 2025-08-02

mapping_id: crm_customer_mapping_v1
source:
  type: database
  source_id: crm_mysql
  table: crm_customer
ontology:
  version: customer360_v1.3
target:
  concept: Customer
identity:
  source_id_field: customer_id
  entity_id_rule: "Customer:${customer_id}"
fields:
  customer_name:
    property: Customer.name
    transform: trim
    required: true
  customer_level:
    property: Customer.level
    enum_mapping:
      A: Strategic
      B: Key
      C: Normal
  industry_code:
    property: Customer.industry
    lookup: industry_dictionary
relations:
  - type: Customer-belongsTo-Industry
    source_field: industry_code
    target_lookup: Industry.code
metadata:
  source_system: CRM
  permission_field: data_scope

规范名

华东设备有限公司

别名

华东设备 · 华东设备有限责任公司

统一信用代码

91320200H88126XY

所属行业

制造业 · 通用设备

等级

Strategic · A

信用额度

¥ 12,000,000

置信度

0.96

审核状态

approved

{
  "entity_id": "Customer:000123",
  "source_records": [
    { "source_system": "CRM", "source_id": "C001" },
    { "source_system": "ERP", "source_id": "ERP-C-9981" },
    { "source_system": "DMS", "source_id": "Vendor-77" }
  ],
  "confidence": 0.96,
  "review_status": "approved"
}

PREFIX c360: <https://atlas/onto/customer360#>
PREFIX rdf:  <http://www.w3.org/1999/02/22-rdf-syntax-ns#>

SELECT ?eq ?fault ?wo
WHERE {
  ?cust  rdf:type        c360:Customer ;
         c360:owns       ?eq .
  ?eq    c360:hasFault   ?fault .
  ?fault c360:triggers   ?wo .
  FILTER regex(str(?cust), "华东设备")
}
LIMIT 50

• 实体节点 2,418,902 + 18 万 / 24h
• 关系边 9,742,118 avg degree 4.0
• 三元组 21.4 M RDF
• SPARQL 平均耗时 180 ms
• Gremlin 平均耗时 96 ms

POST /openrag/kbs              // 知识库
GET  /openrag/kbs/{kb_id}
DEL  /openrag/kbs/{kb_id}

POST /openrag/documents/ingest // 文档
POST /openrag/documents/{id}/reindex
DEL  /openrag/documents/{id}

POST /openrag/retrieve         // 检索
POST /openrag/flows/{name}     // Langflow
GET  /openrag/citations/{cid}
GET  /openrag/health

• 统一租户标识 + 知识库与本体版本绑定
• 文档权限标签传递 / 来源 / 血缘字段
• Chunk 与 Entity 关联 + Evidence Registry
• OpenSearch 索引命名规范
• 企业统一认证 / 审计 / 监控
• 删除传播 / 权限变更后索引更新
• 降级模式：仅 OpenSearch 关键词 + 向量

{
  "tool_id": "create_work_order",
  "tool_name": "创建设备维修工单",
  "source_system": "EAM",
  "input_concepts": [
    "Equipment", "FaultEvent",
    "MaintenanceAction"
  ],
  "output_concepts": ["WorkOrder"],
  "permission": "workorder:create",
  "risk_level": "L3",
  "human_confirm": true,
  "write_operation": true,
  "rollback": true,
  "audit_level": "full",
  "rate_limit": "60/min/user",
  "timeout_ms": 8000
}

create_work_order {
  equipment_id: "Equipment:A",
  fault_event_id: "FaultEvent:#38",
  priority: "high",
  reason: "压力传感器异常 + 历史维修不彻底",
  evidence_refs: [
    "doc_44e1#chunk_009",
    "doc_44e1#chunk_017"
  ],
  proposed_action: "更换压力传感器 + 动平衡测试"
}

• ◆ 合同审查 CopilotL3 · 12 任务/h
• ◆ 设备故障代理L3 · 8 任务/h · 当前
• ◆ 客户 360 智询L1 · 240 任务/h
• ◆ 供应商风险助手L2 · 14 任务/h
• ◆ 合规问答L0 · 188 任务/h
• ◆ 运维 CopilotL2 · 41 任务/h
• ◆ 报告草稿生成L0 · 32 任务/h

• 意图识别 / 概念对齐 / 任务规划
• GraphRAG / KG / Rule 调用
• 工具选择 / Policy 校验
• 人工确认 / 回退
• 失败重试 / 任务恢复
• 执行结果回写 + 审计

package atlas.tools

default allow = false

allow {
  input.tool.risk_level <= "L1"
  has_permission(input.user, input.tool.permission)
}

require_human_review {
  input.tool.risk_level == "L3"
} else {
  input.tool.risk_level == "L4"
  input.tool.policy_override == true
}

deny["cross-tenant"] {
  input.tool.tenant_scope == "single"
  input.user.tenant != input.target.tenant
}

deny["sensitive-doc"] {
  input.target.security_level == "L4"
  not input.user.roles["legal"]
}

• 当前 tenant_001 主集团
• 在线 tenant_002 华南分公司
• 在线 tenant_003 海外

• L0 公开
• L1 内部公开
• L2 内部受限
• L3 机密
• L4 绝密

// 角色 sales 的客户访问
allow read entity:Customer
  where data_scope.region in user.regions
    and data_scope.dept   == user.dept

// 文档 ACL · 合同密级
allow read doc
  where doc.security_level <= user.clearance
    and doc.acl.contains(user.role)

// 字段脱敏
mask field Customer.creditLimit
  if user.role not in (finance, legal)

• ① 检索 前置 过滤（OpenSearch query 注入）
• ② 服务层 二次 过滤（API gateway）
• ③ Agent 工具 调用前 (Policy Gateway)
• ④ 字段 脱敏 / 引用裁剪
• ⑤ 反馈与导出 水印

{
  "knowledge_object_id":
    "Entity:Customer:000123",
  "source_system": "CRM",
  "source_object": "crm_customer",
  "source_id": "C001",
  "source_updated_at": "2026-05-18 10:00",
  "ingested_at": "2026-05-18 10:05",
  "pipeline_run_id": "run_8821",
  "mapping_version":
    "crm_customer_mapping_v1",
  "ontology_version":
    "customer360_v1.3",
  "confidence": 0.96,
  "review_status": "approved",
  "reviewed_by": "data-steward-12",
  "reviewed_at": "2026-05-18 10:12"
}

反馈采集
  ↓
问题分类（幻觉 / 检索 / 本体 / 规则 / 工具）
  ↓
定位原因（trace + provenance）
  ↓
生成修复任务（Issue + 责任人）
  ↓
更新 文档 / 图谱 / 本体 / 规则 / Prompt
  ↓
重新索引（OpenSearch + Graph）
  ↓
评测验证（回归数据集）
  ↓
发布

• 合同付款条款歧义 8 次
• 设备别名 / 旧编号 6 次
• 规则 RULE-DOWNTIME-30 例外 4 次
• 工具 create_work_order schema 3 次

// 默认分工
RDF / Jena Fuseki  → 本体 · TBox · SHACL · 命名空间
HugeGraph          → 业务实例 · 多跳 · 图分析

// 同步：事件驱动 · 单向派生
Mapping/Ontology "published" event
  → derive vertex/edge labels
  → idempotent upsert

• Secret / KMS · 凭据轮换
• 内网镜像以 digest 固定 · SBOM
• 南北向网关 · 东西向 mTLS
• 供应链：镜像签名 / 物料清单