iot-rule-engine

为持续运行的边缘规则而设计。

IoT Rule Engine 将规则管理、DAG 调度、插件执行和运行监控集中在一个系统中。插件以独立进程隔离,物理连接依据真实需求持有,协议差异不会泄漏到规则编排层。

Four runtime planes

一个入口,四类职责。

Manager 是统一控制面;Ingress 接收外部事件;Pipeline 路由到规则;Executor 调度 DAG 节点与插件实例。

MANAGER

配置与运维

规则、插件、Connector 资源、用户、系统配置与运行态 API,默认端口 11011。

INGRESS

协议入口

接收 HTTP 与 MQTT 事件,经内置或外部 NATS 进入规则路由。

PIPELINE

确定性路由

按规则 source topic 分发事件,过载路径有界,失败进入可观测处理路径。

EXECUTOR

DAG 执行

每个调度分支独占 Event,运行时字段与业务 Metadata 分离,避免并发别名。

PLUGIN HOST

进程隔离

同一 artifact 只启动一个进程,每个规则节点由 ServeFactory 创建独立对象。

CONNECTORS

需求感知会话

S7 高频扫描窗口复用连接,低频批次及时释放;MQTT 保持适合协议的持久连接。

Default flow

采集、处理、输出,一条可观测链路。

典型规则由 Connector 资源、Source、零到多个 Processor 和 Sink 组成。配置只引用资源,不在规则节点复制密码。