Publish read-only edge adapters and generic PLC tag examples

edge/inference_onnx.py

@@ -0,0 +1,50 @@
+#!/usr/bin/env python3
+"""Run the public pump surrogate with ONNX Runtime on CPU."""
+
+from __future__ import annotations
+
+import argparse
+import json
+from pathlib import Path
+
+import numpy as np
+import onnxruntime as ort
+
+FEATURE_ORDER = (
+    "speed_fraction",
+    "static_head_m",
+    "system_k",
+    "voltage_fraction",
+    "ambient_temp_c",
+    "inlet_pressure_bar",
+)
+TARGET_ORDER = (
+    "flow_m3h",
+    "total_head_m",
+    "input_power_kw",
+    "winding_temp_c",
+    "npsh_margin_m",
+    "efficiency_fraction",
+)
+
+
+def predict(model_path: Path, values: list[float]) -> dict[str, float]:
+    if len(values) != len(FEATURE_ORDER):
+        raise ValueError(f"expected {len(FEATURE_ORDER)} values")
+    session = ort.InferenceSession(str(model_path), providers=["CPUExecutionProvider"])
+    output = session.run(["outputs"], {"features": np.asarray([values], dtype=np.float32)})[0][0]
+    return {name: float(value) for name, value in zip(TARGET_ORDER, output, strict=True)}
+
+
+def main() -> int:
+    parser = argparse.ArgumentParser()
+    parser.add_argument("--model", type=Path, default=Path("onnx/model.onnx"))
+    parser.add_argument("values", nargs=6, type=float, metavar="VALUE")
+    args = parser.parse_args()
+    print(json.dumps({"feature_order": FEATURE_ORDER, "prediction": predict(args.model, args.values)}, indent=2))
+    return 0
+
+
+if __name__ == "__main__":
+    raise SystemExit(main())
+

edge/plc_guard.py

@@ -0,0 +1,29 @@
+"""Read-only advisory boundary around pump-surrogate predictions.
+
+This module has no network, PLC, OPC UA, S7, or Modbus client. It cannot write
+to a controller. Certified equipment protection and emergency shutdown logic
+must remain in an independently engineered PLC/SIS layer.
+"""
+
+from __future__ import annotations
+
+
+def advisory(features: dict[str, float], prediction: dict[str, float]) -> dict[str, object]:
+    reasons: list[str] = []
+    if features["voltage_fraction"] < 0.90:
+        reasons.append("undervoltage_demo_threshold")
+    if prediction["npsh_margin_m"] < 1.0:
+        reasons.append("cavitation_margin_demo_threshold")
+    if prediction["winding_temp_c"] > 70.0:
+        reasons.append("thermal_demo_threshold")
+    if features["speed_fraction"] > 0.35 and prediction["flow_m3h"] < 0.20:
+        reasons.append("no_flow_demo_threshold")
+    if prediction["input_power_kw"] > 3.2:
+        reasons.append("overload_demo_threshold")
+    return {
+        "mode": "read_only_advisory",
+        "severity": "review" if reasons else "nominal",
+        "reasons": reasons,
+        "automatic_write_allowed": False,
+        "operator_or_safety_system_decision_required": bool(reasons),
+    }

edge/tag_map.yml

@@ -0,0 +1,33 @@
+schema_version: 1
+profile: generic_pump_demo_read_only
+write_enabled: false
+note: >-
+  Illustrative symbolic mappings only. Siemens is a trademark of its owner;
+  this project is not affiliated with or validated by Siemens. No PLC client
+  or controller write path is included.
+signals:
+  speed_fraction:
+    opcua_node: "ns=2;s=PumpDemo.SpeedFraction"
+    modbus_input_register: 30001
+    s7_symbolic: "DB_PUMP_DEMO.SpeedFraction"
+  static_head_m:
+    opcua_node: "ns=2;s=PumpDemo.StaticHeadM"
+    modbus_input_register: 30003
+    s7_symbolic: "DB_PUMP_DEMO.StaticHeadM"
+  system_k:
+    opcua_node: "ns=2;s=PumpDemo.SystemK"
+    modbus_input_register: 30005
+    s7_symbolic: "DB_PUMP_DEMO.SystemK"
+  voltage_fraction:
+    opcua_node: "ns=2;s=PumpDemo.VoltageFraction"
+    modbus_input_register: 30007
+    s7_symbolic: "DB_PUMP_DEMO.VoltageFraction"
+  ambient_temp_c:
+    opcua_node: "ns=2;s=PumpDemo.AmbientTempC"
+    modbus_input_register: 30009
+    s7_symbolic: "DB_PUMP_DEMO.AmbientTempC"
+  inlet_pressure_bar:
+    opcua_node: "ns=2;s=PumpDemo.InletPressureBar"
+    modbus_input_register: 30011
+    s7_symbolic: "DB_PUMP_DEMO.InletPressureBar"
+