industrial-aiops iaiops-warehouse — 仓储 / 物料搬运 edition（EtherNet/IP + Profinet + Modbus + OPC-UA + Sparkplug + 脑）
启动：IAIOPS_MCP=warehouse / iaiops-mcp-warehouse（= eip + profinet + modbus + opcua
- sparkplug + 脑；等价显式写法
IAIOPS_MCP=eip,profinet,modbus,opcua,sparkplug）。 EtherNet/IP 需 extra：pip install iaiops[eip]。典型现场：输送/分拣 PLC 走 EtherNet/IP(Rockwell) 或 Profinet(Siemens),驱动/表计走 Modbus,WMS/WCS 网关走 OPC-UA,AGV/AMR 与 IoT 传感走 MQTT-Sparkplug。
定位：复用既有跨协议脑的 PdM（
pdm_forecast）/ 停机分诊（downtime_triage）/ OEE / 告警 能力,针对物料搬运资产(输送带电机轴承、分拣驱动、AGV 电池)对症使用,提供 物料搬运专用的 Modbus 模板,并带一个 仓储专属 edition 工具line_bottleneck(瓶颈工位定位;仅随本 edition 加载,不进全局脑)。
工具
EtherNet/IP（Rockwell 输送/分拣 PLC；写=MOC）
eip_controller_info— 控制器身份/状态eip_list_tags— 控制器 tag 列表eip_read_tag/eip_read_many— 读单/多 tag（输送段状态、分拣计数、速度）eip_write_tag— [WRITE][HIGH][MOC] 写 tag（默认dry_run=True+ 改前值 undo + 双确认）plctype入参（或 config key）选驱动：logix（默认 Logix 符号 tag）、slc（老 AB 输送/分拣 PLC-5/SLC-500/MicroLogix 走 PCCC 数据表N7:0/B3:0/0/F8:0）、micro800。真 PCCC/Micro800 待核实。
Profinet（Siemens 物料搬运线）
profinet_discover— DCP 发现网上 IO 设备/stationprofinet_identify_station/profinet_station_params— station 身份与参数profinet_asset_inventory— IO 设备资产清单profinet_dcp_set— [WRITE][HIGH][MOC] DCP 设置站名/IP（默认 dry-run + 双确认）
Modbus-TCP / RTU（只读；VFD 驱动、能耗表、AGV 电池 BMS）
modbus_read_holdingmodbus_read_inputmodbus_read_coilsmodbus_read_discretemodbus_detect_byte_order— 字节/字序自动探测（驱动浮点/32 位常见坑）modbus_list_templates/modbus_apply_template— 厂商寄存器模板 → 命名 tag （物料搬运模板：conveyor_vfd输送/分拣 VFD 遥测、agv_batteryAGV/AMR 电池；均待核实）modbus_health_summary— 寄存器 vs 阈值分类（如驱动温度/电流带）
OPC-UA（只读；WMS/WCS 网关、线体 SCADA）
opcua_server_info/opcua_browse/opcua_read_node/opcua_read_manyopcua_subscribe_sampleopcua_read_alarmsopcua_alarm_events(A&C 带时间戳)opcua_read_history(HDA)opcua_diagnose_connection— 连接失败归因（证书/策略/认证/网络/配置）opcua_discover_tags— 自动发现 + 语义资产建模；opcua_health_summary阈值分类;opcua_anomaly_scan有界统计异常扫描
MQTT-Sparkplug B（可选；AGV/AMR 车队、IoT 传感/网关的 UNS）
sparkplug_node_listsparkplug_subscribe_samplesparkplug_decode_payloadmqtt_read_topicmqtt_publishsparkplug_live_schemauns_browseuns_topic_audituns_schema_driftuns_live_audituns_live_drift
仓储专属（edition 工具;仅随 warehouse edition 加载,不进全局脑）
line_bottleneck— 产线/物料搬运瓶颈工位定位(约束理论 TOC:最低吞吐工位即瓶颈, 设定整线速率;starved/blocked 佐证——瓶颈上游被 blocked、下游被 starved)。纯分析, 喂 WMS/WCS/MES/PLC 计数的每工位吞吐或节拍,worst-first,每项引用数值。sortation_health— 分拣机读码率/无读/误分拣分析:按每件分拣记录(是否读到条码、 应分/实分格口)算三率对标,排出误分拣最多的格口(卡阻/映射错)。纯分析,读 WCS/分拣 PLC 事件。
跨协议脑（永远随 server 暴露）
- 诊断：
diagnose_dataflowdowntime_root_causedowntime_root_cause_livedowntime_triagelearn_cause_weightsrca_corpus_from_maintenancehistorian_healthalarm_bad_actorstag_healthsubscription_healthheartbeat_healthalarm_flood_analysisalarm_cascadealarm_rationalization_worksheet - 预测维护：
pdm_forecast—— 输送带电机轴承/温升、分拣驱动、AGV 电池的趋势 + 到限时间 （早于baseline_check的越带告警;喂conveyor_vfd/agv_battery模板读出的温度/电流） - 告警事件聚类：
alarm_event_clusters—alarm_bad_actors按来源排名,回答的是「哪台仪表最吵」, 不是「哪个故障最吵」;一个把同一条件写成十种说法的厂会得到十个 bad actor。这个按事件说了什么分组。 合并规则是去掉大小写/标点/数字后的精确相等,不是相似度 —— 故意做笨,所以不需要模型、且可核对; 每个簇都列出被合并的原文与来源。它不主张两条措辞不同的告警是同一个故障,那由人判断。 - 数据质量：
data_quality_scorecarddata_quality_fleet_rollup - 分析：
oee_computedowntime_eventsoee_multidimmonitor_changes - 上下文基线：
baseline_learn_contextualbaseline_check_in_context—— 一个位号只学一条带, 在它有不止一个「正常」时就是错的(同一台干燥机 recipe A 走 180 °C、B 走 240 °C,一条带横跨两者, 于是两个工况都不可能出错)。上下文由人声明,绝不推断(D16);某个上下文历史太薄就拒学, 不借用别的上下文的样本;读数落在没学过的上下文里报unknown_context,绝不回落到全局带 —— 回落等于把「这个工况从没见过」说成「这个工况正常」。 - 上下游归因：
downtime_attribution—— RCA 只按时间加权,所以一次上游停机会让每台下游设备 各自给出一个自信的本地根因。方向来自声明的产线顺序(D25:产线上共现是必然,拿它挖边等于 制造因果),顺序来自时间戳,两者都要成立;没声明关系就报not_evaluable并给出补法。 - 资产：
asset_inventorycross_protocol_asset_modeladopt_alias_mapdiff_alias_map - 设备公告对照：
device_advisory_check——scan早就在读 vendor/model/firmware,却什么都没做。 这条把它接上,并刻意停在漏洞扫描器会继续往前走的地方:只报「落在公告声明的版本范围内」, 不说「可利用」、不给严重度 —— 可达性与补偿控制决定那件事,而只读扫描看不见它们。 不内置任何 CVE 库(过期却看着像最新的库比没有更糟),由现场挂载文件、离线可用,每条必须带来源。 读不出固件报version_unknown,读得出但排不了序报version_unparsed—— 都不算通过; 公告没提到的设备不出现在结果里,那是「未知」不是「没有」。 - 基线：
baseline_learnbaseline_checkbaseline_record_changebaseline_status - 合规/信创：
compliance_mappingcompliance_frameworkscompliance_dengbao_levelscompliance_reportcompliance_evidence_bundlehistorian_pushexport_datahistorian_queryhistorian_coveragestream_publishuns_publishstream_publish_eventrca_narratefleet_statusfleet_incidents - 程序解读：
plc_program_outlineplc_program_xrefplc_program_sectionplc_program_visibility - 程序变更基线：
plc_program_snapshotplc_program_driftplc_program_history— 把「认可的那一版」 的结构记下来（文件 SHA-256 + 每个 block 的结构指纹：声明/调用/分支条件/定时器，不含行号、注释、 block 顺序，所以在文件顶上加一行注释不会把整份程序报成变更），之后问某一次导出动没动。 三个判词咬得很紧：identical只由 SHA-256 相同得出；logic_changed逐 block 指出哪一类变了；changed_outside_extracted_structure= 字节变了而结构指纹全同 —— 多半是注释/排版，但这些 parser 是结构抽取不是文法，所以它不叫「仅文档」，也不构成放行。删历史只在 CLI（iaiops program forget）： 删变更控制证据不该离 agent 只有一次调用。存的是 block 名 + 哈希 + 计数，不落声明、源码行和注释。 - 自证：
verify_determinism— 把「拿掉模型、断网、同一份数据重跑、输出逐字节相同」跑出来： 固定数据集过一遍分析层，规范化后取 SHA-256，在本进程跑两遍、再在两个不同 PYTHONHASHSEED 的 全新解释器里各跑一遍（这一臂才抓得到集合/字典迭代顺序渗进结果），全程 socket 抛异常。 给 CSV/验证团队的是一条能写进 IQ/OQ 的测试用例，不是一句形容词。 - 元：
protocols_supported(产品能做什么)·site_readiness(这个站点今天能跑什么、还差什么;零联网) ·onboarding_status(这个站点走到哪一步了、下一条命令是什么;零联网) ·onboarding_config_draft(把已存的 scan 变成 config.yaml 端点草稿 —— 只写连接事实：value: null的字段是扫描没确认的，照抄它的caution，别替人填也别删；tags永远是空的， 点位语义只能人来确认iaiops tags export|apply) - 调查层（§13，八步证据闭环）：
investigation_readinessinvestigation_openinvestigation_showinvestigation_list— 「真出事时这个站能走到第几步、每个缺口还差什么」，以及对一个已过去的窗口 逐步走完并留档（不碰设备）。缺口分两种:你没供(给命令) 与 产品供不了。 - 产线关系与机制库：
line_relation_declareline_relations_listmechanism_library_checkmechanism_library_list— 上下游由人声明（D25:线上下游共现是必然，推不出因果）； 机制库按 ISO 14224 分 mode/mechanism/cause，可排除、绝不确认， 库里没有这条原因 →nothing_known（不是「无异议」）。
Workflows
- Doctor-first：
protocols_supported→iaiops doctor→ EtherNet/IP 先eip_controller_info,OPC-UA 先opcua_diagnose_connection。 - 输送带 PdM：
modbus_apply_template(conveyor_vfd) 读 drive_temperature / motor_current 序列 →pdm_forecast(warn_high=...)估到限时间 →imminent/degrading即提前派维护。AGV 车队同理用agv_battery模板 +pdm_forecast盯 SOC/温度衰减。 - 停机分诊：分拣线停机 =
downtime_triage(告警 cascade + RCA + PdM 前兆一次给出), 或downtime_root_cause_live现采证据链;吞吐掉速用 OEE/oee_multidim定位瓶颈工位。 - MOC 写：本 edition 读优先;EtherNet/IP
eip_write_tag、Profinetprofinet_dcp_set为写工具,统一走 MOC:risk=HIGH+ 默认dry_run=True+ 改前值 undo +iaiops approve具名审批双确认。未经授权绝不写生产控制系统。
支持版本矩阵（内部 HLD §8，设计文档不随本仓发布;待核实 不得当既成事实）
| 协议 | 库(pin) | 规范/版本 | 覆盖 | 传输 | 自测 |
|---|---|---|---|---|---|
| EtherNet/IP | pycomm3>=1.2,<2（extra） |
CIP / EtherNet/IP；Logix tag + PCCC 数据表 | AB/Rockwell ControlLogix/CompactLogix + PLC-5/SLC-500/MicroLogix（PCCC）+ Micro800（plctype 选） |
TCP/44818 | ⚠️ mock（含 SLCDriver）；真 PLC 待核实 |
| Profinet | pnio-dcp>=1.1,<3（extra） |
PN-DCP（发现/命名） | 现场 IO 设备/station | Ethernet(raw)/UDP | ⚠️ 发现层自测;真设备 待核实 |
| Modbus-TCP | pymodbus>=3.5,<4 |
App 1.1b3；FC 1/2/3/4/5/6/15/16 | VFD/能耗表/AGV BMS/任意从站 | TCP/502 | ✅ |
| Modbus-RTU | pymodbus>=3.5,<4 + pyserial>=3.5 |
Modbus serial (RTU) | 串口从站/表计 | RS-485/serial | ✅ socat PTY;物理 RS-485 待核实 |
| OPC-UA | asyncua>=2.0,<3 |
OPC UA 1.0x（DA+HA+AC 子集） | WMS/WCS 网关 / SCADA | opc.tcp | ✅ mock+HDA |
| MQTT-Sparkplug B | paho-mqtt>=2.0,<3（extra） |
Sparkplug B 3.0 | AGV/AMR / IoT 网关 UNS | MQTT/1883/8883 | ✅ broker mock |