数字孪生部署

部署 4 个智能体：sensor-bridge、model-engine、anomaly-detector 和 action-planner。

角色说明

部署流程

步骤 1： 向用户询问该智能体应承担的角色及所用前缀（prefix）。

步骤 2： 为选定角色安装对应的能力（skills）：

# sensor-bridge：
clawhub install pilot-stream-data pilot-metrics pilot-gossip
# model-engine：
clawhub install pilot-dataset pilot-task-router pilot-consensus
# anomaly-detector：
clawhub install pilot-event-filter pilot-alert pilot-audit-log
# action-planner：
clawhub install pilot-webhook-bridge pilot-cron pilot-slack-bridge

步骤 3： 设置主机名，并将配置清单（manifest）写入 ~/.pilot/setups/digital-twin.json。

步骤 4： 告知用户需与其角色对应的对等节点（peers）发起握手（handshake）。

各角色的清单模板（Manifest Templates）

sensor-bridge

{
  "setup": "digital-twin", "role": "sensor-bridge", "role_name": "Sensor Bridge",
  "hostname": "-sensor-bridge",
  "skills": {
    "pilot-stream-data": "Ingest real-time sensor telemetry from physical assets.",
    "pilot-metrics": "Track sensor health, sampling rates, and data quality.",
    "pilot-gossip": "Discover and sync with peer sensor bridges."
  },
  "data_flows": [{ "direction": "send", "peer": "-model-engine", "port": 1002, "topic": "telemetry", "description": "Unified telemetry stream from physical assets" }],
  "handshakes_needed": ["-model-engine"]
}

model-engine

{
  "setup": "digital-twin", "role": "model-engine", "role_name": "Model Engine",
  "hostname": "-model-engine",
  "skills": {
    "pilot-dataset": "Store physics model parameters and simulation state.",
    "pilot-task-router": "Route simulation tasks across asset models.",
    "pilot-consensus": "Reconcile model state across redundant engines."
  },
  "data_flows": [
    { "direction": "receive", "peer": "-sensor-bridge", "port": 1002, "topic": "telemetry", "description": "Real-time sensor data" },
    { "direction": "send", "peer": "-anomaly-detector", "port": 1002, "topic": "prediction", "description": "Expected behavior baselines and drift metrics" }
  ],
  "handshakes_needed": ["-sensor-bridge", "-anomaly-detector"]
}

anomaly-detector

{
  "setup": "digital-twin", "role": "anomaly-detector", "role_name": "Anomaly Detector",
  "hostname": "-anomaly-detector",
  "skills": {
    "pilot-event-filter": "Filter predictions by drift threshold and severity.",
    "pilot-alert": "Emit anomaly alerts for critical deviations.",
    "pilot-audit-log": "Log all detected anomalies with evidence snapshots."
  },
  "data_flows": [
    { "direction": "receive", "peer": "-model-engine", "port": 1002, "topic": "prediction", "description": "Model predictions to compare" },
    { "direction": "send", "peer": "-action-planner", "port": 1002, "topic": "anomaly-alert", "description": "Anomaly alerts with severity and root cause" }
  ],
  "handshakes_needed": ["-model-engine", "-action-planner"]
}

action-planner

{
  "setup": "digital-twin", "role": "action-planner", "role_name": "Action Planner",
  "hostname": "-action-planner",
  "skills": {
    "pilot-webhook-bridge": "Push maintenance orders to field team systems.",
    "pilot-cron": "Schedule maintenance windows during low-impact periods.",
    "pilot-slack-bridge": "Notify operations teams of recommended interventions."
  },
  "data_flows": [
    { "direction": "receive", "peer": "-anomaly-detector", "port": 1002, "topic": "anomaly-alert", "description": "Anomaly alerts to act on" },
    { "direction": "send", "peer": "external", "port": 443, "topic": "maintenance-order", "description": "Work orders to field management systems" }
  ],
  "handshakes_needed": ["-anomaly-detector"]
}

数据流向

• sensor-bridge → model-engine：来自物理资产的实时遥测数据（端口 1002）
• model-engine → anomaly-detector：预测结果与预期行为基线（端口 1002）
• anomaly-detector → action-planner：含严重等级与根因分析的异常告警（端口 1002）
• action-planner → external：下发至现场团队系统的维护工单（端口 443）

工作流示例

# 在 sensor-bridge 上 —— 推送遥测数据：
pilotctl --json publish -model-engine telemetry '{"asset_id":"PUMP-A7","sensors":{"temperature_c":87.3,"vibration_mm_s":4.2}}'
# 在 model-engine 上 —— 发送预测结果：
pilotctl --json publish -anomaly-detector prediction '{"asset_id":"PUMP-A7","drift_pct":{"temperature":6.3,"vibration":50.0}}'
# 在 anomaly-detector 上 —— 向 action-planner 发送告警：
pilotctl --json publish -action-planner anomaly-alert '{"asset_id":"PUMP-A7","severity":"warning","anomaly_type":"bearing_degradation"}'

依赖项

需具备 pilot-protocol 能力、pilotctl 可执行文件、clawhub 可执行文件，以及一个正在运行的守护进程（daemon）。