规则引擎应用

规则引擎应用用于将 EMQX Neuron 数采模块的数据发送到数据处理模块。

在 EMQX Neuron 的北向应用 页面已经默认配置的 规则引擎应用 类型的节点 DataProcessing，并做好了参数配置。用户只需要将南向驱动数据添加订阅到DataProcessing节点即可。

添加订阅

点击操作栏中的添加订阅，在订阅南向驱动数据中展开驱动节点，勾选要订阅的采集组：

规则引擎应用不需要填主题，数据直接进入数据处理模块。

至此，我们将能通过 DataProcessing 节点 将南向驱动m1的group1组中的数据，发送到数据处理模块的 neuronStream流里进行下一步处理。

有关在数据处理模块中的操作，见neuronStream。

提示

当数据处理模块中的neuronStream流，在规则中使用并有数据流入后，DataProcessing节点的连接状态才会变为已连接。

数据格式

通过 Dataprocessing 节点发送到neuronStream的消息为固定的 json 格式，如下所示：

{
  "timestamp": 1646125996000,
  "node_name": "node1", 
  "group_name": "group1",
  "values": {
    "tag_name1": 11.22,
    "tag_name2": "string"
  },
  "errors": {},
  "metas":{}
}

反向控制

数据处理模块通过Neuron Sink可以通过 DataProcessing 节点，向南向驱动下发写命令来控制设备。关于这部分的详细操作，见Neuron Sink。