平台中内置了规则引擎,,均由规则引擎执行.

名词说明:

• RuleModel(规则模型):由多个,组成
• RuleNode(规则节点): 规则节点描述具体执行的逻辑
• RuleLink(规则连线): 用于将多个节点连接起来,将上一个节点的输出结果作为下一个节点的输入结果.
• Input(输入): 规则节点的数据输入
• Output(输出): 规则节点的数据输出
• Scheduler(调度器): 负责将模型转为任务(),并进行任务调度到
• Worker(工作器): 负责执行,维护任务.
• ExecutionContext(执行上下文): 启动任务时的上下文,通过上下文获取输入输出配置信息等进行任务处理.
• TaskExecutor(任务执行器): 具体执行任务逻辑的实现
• TaskExecutorProvider(任务执行器提供商): 用于根据模型配置以及上下文创建任务执行器.
• RuleData(规则数据): 任务执行过程中的数据实例

1. 实现接口
2. 在中配置Bean

脚本说明

脚本使用jsr223引擎, 通过调用内置变量handler.onMessage注册消息监听函数,当上游产生数据时,此函数将被调用,并传入数据.

例如:

通过指定输出数量值,可以控制输出到指定的节点,如:

你还可以通过上下文作用域保存,获取数据.

作用域

• ctx.scope(String id)或者ctx.scope(RuleData ruleData)上下文作用域,根据ruleData.contextId决定.
• ctx.node()当前节点作用域
• ctx.node(String id)指定节点作用域
• ctx.flow()当前流程作用域
• ctx.flow(String id)指定流程作用域
• ctx.flow(String id).node(String id)指定流程指定节点的作用域
• ctx.global()全局作用域

作用域支持方法:

• .all(String... key)获取指定key的数据,如果未指定这返回全部,类型为Mono<Map<String,Object>>
• .get(String key)获取指定key的数据,返回类型为Mono<Object>
• .put(String key,Object value)设置值,返回类型为Mono<Void>
• .putAll(Map<String,Object>)设置多个值,参数为Map,返回类型为Mono<Void>
• .clear()清空作用域,返回类型为Mono<Void>
• .counter()获取计数器
• .counter(String name)获取指定名字的计数器
• .counter().inc(double number)计数器递增,返回最新值:Mono<Double>
• .counter().dec(double number)计数器递减,返回最新值:Mono<Double>
• .counter().getAndSet(double number)获取最新值后设置新的值,返回:Mono<Double>
• .counter().setAndGet(double number)设置最新值后返回最新的值,返回:Mono<Double>

日志输出和错误处理

使用以下功能输出日志：

ctx.getLogger().debug("Log message {}",data); ctx.getLogger().warn("Warning"); ctx.getLogger().error("Error"); 使用以下功能触发错误：

throw new Error("错误"); throw new java.lang.RuntimeException("错误");

设备选择器说明

如果下发指令的设备是动态获取的，可使用表达式函数来获取设备并发送到对应到设备。

例如:

• 获取产品ID为demo-device的设备:

• 获取分组为demo-group下的设备:

• 获取当前设备相同分组下的设备:

• 获取标签supplier为测试厂商下的设备:

• 按状态筛选 :,状态:

• 函数的参数可以是固定的字符串,如:,也可以是上游节点传递的变量,如:

• 多个表达式使用,分隔,例如: